airflow.providers.google.cloud.operators.dlp

This module contains various Google Cloud DLP operators which allow you to perform basic operations using Cloud DLP.

Module Contents

class airflow.providers.google.cloud.operators.dlp.CloudDLPCancelDLPJobOperator(*, dlp_job_id: str, project_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Starts asynchronous cancellation on a long-running DlpJob.

See also

For more information on how to use this operator, take a look at the guide: Canceling a Job

Parameters

  • dlp_job_id (str) -- ID of the DLP job resource to be cancelled.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. If set to None or missing, the default project_id from the Google Cloud connection is used.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

template_fields = ['dlp_job_id', 'project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPCreateDeidentifyTemplateOperator(*, organization_id: Optional[str] = None, project_id: Optional[str] = None, deidentify_template: Optional[Union[Dict, DeidentifyTemplate]] = None, template_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Creates a DeidentifyTemplate for re-using frequently used configuration for de-identifying content, images, and storage.

See also

For more information on how to use this operator, take a look at the guide: De-Identification Template

Parameters

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • deidentify_template (dict or google.cloud.dlp_v2.types.DeidentifyTemplate) -- (Optional) The DeidentifyTemplate to create.

  • template_id (str) -- (Optional) The template ID.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.DeidentifyTemplate

template_fields = ['organization_id', 'project_id', 'deidentify_template', 'template_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPCreateDLPJobOperator(*, project_id: Optional[str] = None, inspect_job: Optional[Union[Dict, InspectJobConfig]] = None, risk_job: Optional[Union[Dict, RiskAnalysisJobConfig]] = None, job_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, wait_until_finished: bool = True, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Creates a new job to inspect storage or calculate risk metrics.

See also

For more information on how to use this operator, take a look at the guide: Creating Job

Parameters

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. If set to None or missing, the default project_id from the Google Cloud connection is used.

  • inspect_job (dict or google.cloud.dlp_v2.types.InspectJobConfig) -- (Optional) The configuration for the inspect job.

  • risk_job (dict or google.cloud.dlp_v2.types.RiskAnalysisJobConfig) -- (Optional) The configuration for the risk job.

  • job_id (str) -- (Optional) The job ID.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • wait_until_finished (bool) -- (Optional) If true, it will keep polling the job state until it is set to DONE.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.DlpJob

template_fields = ['project_id', 'inspect_job', 'risk_job', 'job_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPCreateInspectTemplateOperator(*, organization_id: Optional[str] = None, project_id: Optional[str] = None, inspect_template: Optional[InspectTemplate] = None, template_id: Optional[Union[Dict, InspectTemplate]] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Creates an InspectTemplate for re-using frequently used configuration for inspecting content, images, and storage.

See also

For more information on how to use this operator, take a look at the guide: Creating Template

Parameters

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • inspect_template (dict or google.cloud.dlp_v2.types.InspectTemplate) -- (Optional) The InspectTemplate to create.

  • template_id (str) -- (Optional) The template ID.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.InspectTemplate

template_fields = ['organization_id', 'project_id', 'inspect_template', 'template_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPCreateJobTriggerOperator(*, project_id: Optional[str] = None, job_trigger: Optional[Union[Dict, JobTrigger]] = None, trigger_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Creates a job trigger to run DLP actions such as scanning storage for sensitive information on a set schedule.

See also

For more information on how to use this operator, take a look at the guide: Creating Job Trigger

Parameters

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. If set to None or missing, the default project_id from the Google Cloud connection is used.

  • job_trigger (dict or google.cloud.dlp_v2.types.JobTrigger) -- (Optional) The JobTrigger to create.

  • trigger_id (str) -- (Optional) The JobTrigger ID.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.JobTrigger

template_fields = ['project_id', 'job_trigger', 'trigger_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPCreateStoredInfoTypeOperator(*, organization_id: Optional[str] = None, project_id: Optional[str] = None, config: Optional[StoredInfoTypeConfig] = None, stored_info_type_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Creates a pre-built stored infoType to be used for inspection.

See also

For more information on how to use this operator, take a look at the guide: Create Stored Info-Type

Parameters

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • config (dict or google.cloud.dlp_v2.types.StoredInfoTypeConfig) -- (Optional) The config for the StoredInfoType.

  • stored_info_type_id (str) -- (Optional) The StoredInfoType ID.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.StoredInfoType

template_fields = ['organization_id', 'project_id', 'config', 'stored_info_type_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPDeidentifyContentOperator(*, project_id: Optional[str] = None, deidentify_config: Optional[Union[Dict, DeidentifyConfig]] = None, inspect_config: Optional[Union[Dict, InspectConfig]] = None, item: Optional[Union[Dict, ContentItem]] = None, inspect_template_name: Optional[str] = None, deidentify_template_name: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

De-identifies potentially sensitive info from a ContentItem. This method has limits on input size and output size.

See also

For more information on how to use this operator, take a look at the guide: De-identify Content

Parameters

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. If set to None or missing, the default project_id from the Google Cloud connection is used.

  • deidentify_config (dict or google.cloud.dlp_v2.types.DeidentifyConfig) -- (Optional) Configuration for the de-identification of the content item. Items specified here will override the template referenced by the deidentify_template_name argument.

  • inspect_config (dict or google.cloud.dlp_v2.types.InspectConfig) -- (Optional) Configuration for the inspector. Items specified here will override the template referenced by the inspect_template_name argument.

  • item (dict or google.cloud.dlp_v2.types.ContentItem) -- (Optional) The item to de-identify. Will be treated as text.

  • inspect_template_name (str) -- (Optional) Optional template to use. Any configuration directly specified in inspect_config will override those set in the template.

  • deidentify_template_name (str) -- (Optional) Optional template to use. Any configuration directly specified in deidentify_config will override those set in the template.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.DeidentifyContentResponse

template_fields = ['project_id', 'deidentify_config', 'inspect_config', 'item', 'inspect_template_name', 'deidentify_template_name', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteDeidentifyTemplateOperator(*, template_id: str, organization_id: Optional[str] = None, project_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Deletes a DeidentifyTemplate.

See also

For more information on how to use this operator, take a look at the guide: De-Identification Template

Parameters

  • template_id (str) -- The ID of deidentify template to be deleted.

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

template_fields = ['template_id', 'organization_id', 'project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteDLPJobOperator(*, dlp_job_id: str, project_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Deletes a long-running DlpJob. This method indicates that the client is no longer interested in the DlpJob result. The job will be cancelled if possible.

See also

For more information on how to use this operator, take a look at the guide: Deleting Job

Parameters

  • dlp_job_id (str) -- The ID of the DLP job resource to be cancelled.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. If set to None or missing, the default project_id from the Google Cloud connection is used.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

template_fields = ['dlp_job_id', 'project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteInspectTemplateOperator(*, template_id: str, organization_id: Optional[str] = None, project_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Deletes an InspectTemplate.

See also

For more information on how to use this operator, take a look at the guide: Deleting Template

Parameters

  • template_id (str) -- The ID of the inspect template to be deleted.

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

template_fields = ['template_id', 'organization_id', 'project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteJobTriggerOperator(*, job_trigger_id: str, project_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Deletes a job trigger.

See also

For more information on how to use this operator, take a look at the guide: Content Method

Parameters

  • job_trigger_id (str) -- The ID of the DLP job trigger to be deleted.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. If set to None or missing, the default project_id from the Google Cloud connection is used.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

template_fields = ['job_trigger_id', 'project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteStoredInfoTypeOperator(*, stored_info_type_id: str, organization_id: Optional[str] = None, project_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Deletes a stored infoType.

See also

For more information on how to use this operator, take a look at the guide: Deleting Stored Info-Type

Parameters

  • stored_info_type_id (str) -- The ID of the stored info type to be deleted.

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

template_fields = ['stored_info_type_id', 'organization_id', 'project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPGetDeidentifyTemplateOperator(*, template_id: str, organization_id: Optional[str] = None, project_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Gets a DeidentifyTemplate.

See also

For more information on how to use this operator, take a look at the guide: De-Identification Template

Parameters

  • template_id (str) -- The ID of deidentify template to be read.

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.DeidentifyTemplate

template_fields = ['template_id', 'organization_id', 'project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPGetDLPJobOperator(*, dlp_job_id: str, project_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Gets the latest state of a long-running DlpJob.

See also

For more information on how to use this operator, take a look at the guide: Retrieving Job

Parameters

  • dlp_job_id (str) -- The ID of the DLP job resource to be read.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. If set to None or missing, the default project_id from the Google Cloud connection is used.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.DlpJob

template_fields = ['dlp_job_id', 'project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPGetInspectTemplateOperator(*, template_id: str, organization_id: Optional[str] = None, project_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Gets an InspectTemplate.

See also

For more information on how to use this operator, take a look at the guide: Retrieving Template

Parameters

  • template_id (str) -- The ID of inspect template to be read.

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.InspectTemplate

template_fields = ['template_id', 'organization_id', 'project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPGetDLPJobTriggerOperator(*, job_trigger_id: str, project_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Gets a job trigger.

See also

For more information on how to use this operator, take a look at the guide: Retrieving Job Trigger

Parameters

  • job_trigger_id (str) -- The ID of the DLP job trigger to be read.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. If set to None or missing, the default project_id from the Google Cloud connection is used.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.JobTrigger

template_fields = ['job_trigger_id', 'project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPGetStoredInfoTypeOperator(*, stored_info_type_id: str, organization_id: Optional[str] = None, project_id: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Gets a stored infoType.

See also

For more information on how to use this operator, take a look at the guide: Retrieve Stored Info-Type

Parameters

  • stored_info_type_id (str) -- The ID of the stored info type to be read.

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.StoredInfoType

template_fields = ['stored_info_type_id', 'organization_id', 'project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPInspectContentOperator(*, project_id: Optional[str] = None, inspect_config: Optional[Union[Dict, InspectConfig]] = None, item: Optional[Union[Dict, ContentItem]] = None, inspect_template_name: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Finds potentially sensitive info in content. This method has limits on input size, processing time, and output size.

See also

For more information on how to use this operator, take a look at the guide: Using Template

Parameters

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. If set to None or missing, the default project_id from the Google Cloud connection is used.

  • inspect_config (dict or google.cloud.dlp_v2.types.InspectConfig) -- (Optional) Configuration for the inspector. Items specified here will override the template referenced by the inspect_template_name argument.

  • item (dict or google.cloud.dlp_v2.types.ContentItem) -- (Optional) The item to de-identify. Will be treated as text.

  • inspect_template_name (str) -- (Optional) Optional template to use. Any configuration directly specified in inspect_config will override those set in the template.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.tasks_v2.types.InspectContentResponse

template_fields = ['project_id', 'inspect_config', 'item', 'inspect_template_name', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPListDeidentifyTemplatesOperator(*, organization_id: Optional[str] = None, project_id: Optional[str] = None, page_size: Optional[int] = None, order_by: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Lists DeidentifyTemplates.

See also

For more information on how to use this operator, take a look at the guide: De-Identification Template

Parameters

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • page_size (int) -- (Optional) The maximum number of resources contained in the underlying API response.

  • order_by (str) -- (Optional) Optional comma separated list of fields to order by, followed by asc or desc postfix.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

list[google.cloud.dlp_v2.types.DeidentifyTemplate]

template_fields = ['organization_id', 'project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPListDLPJobsOperator(*, project_id: Optional[str] = None, results_filter: Optional[str] = None, page_size: Optional[int] = None, job_type: Optional[str] = None, order_by: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Lists DlpJobs that match the specified filter in the request.

See also

For more information on how to use this operator, take a look at the guide: Retrieving Job

Parameters

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. If set to None or missing, the default project_id from the Google Cloud connection is used.

  • results_filter (str) -- (Optional) Filter used to specify a subset of results.

  • page_size (int) -- (Optional) The maximum number of resources contained in the underlying API response.

  • job_type (str) -- (Optional) The type of job.

  • order_by (str) -- (Optional) Optional comma separated list of fields to order by, followed by asc or desc postfix.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

list[google.cloud.dlp_v2.types.DlpJob]

template_fields = ['project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPListInfoTypesOperator(*, language_code: Optional[str] = None, results_filter: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Returns a list of the sensitive information types that the DLP API supports.

See also

For more information on how to use this operator, take a look at the guide: Retrieve Stored Info-Type

Parameters

  • language_code (str) -- (Optional) Optional BCP-47 language code for localized infoType friendly names. If omitted, or if localized strings are not available, en-US strings will be returned.

  • results_filter (str) -- (Optional) Filter used to specify a subset of results.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

ListInfoTypesResponse

template_fields = ['language_code', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPListInspectTemplatesOperator(*, organization_id: Optional[str] = None, project_id: Optional[str] = None, page_size: Optional[int] = None, order_by: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Lists InspectTemplates.

See also

For more information on how to use this operator, take a look at the guide: Retrieving Template

Parameters

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • page_size (int) -- (Optional) The maximum number of resources contained in the underlying API response.

  • order_by (str) -- (Optional) Optional comma separated list of fields to order by, followed by asc or desc postfix.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

list[google.cloud.dlp_v2.types.InspectTemplate]

template_fields = ['organization_id', 'project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPListJobTriggersOperator(*, project_id: Optional[str] = None, page_size: Optional[int] = None, order_by: Optional[str] = None, results_filter: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Lists job triggers.

See also

For more information on how to use this operator, take a look at the guide: Retrieving Job Trigger

Parameters

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. If set to None or missing, the default project_id from the Google Cloud connection is used.

  • page_size (int) -- (Optional) The maximum number of resources contained in the underlying API response.

  • order_by (str) -- (Optional) Optional comma separated list of fields to order by, followed by asc or desc postfix.

  • results_filter (str) -- (Optional) Filter used to specify a subset of results.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

list[google.cloud.dlp_v2.types.JobTrigger]

template_fields = ['project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPListStoredInfoTypesOperator(*, organization_id: Optional[str] = None, project_id: Optional[str] = None, page_size: Optional[int] = None, order_by: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Lists stored infoTypes.

See also

For more information on how to use this operator, take a look at the guide: Retrieve Stored Info-Type

Parameters

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • page_size (int) -- (Optional) The maximum number of resources contained in the underlying API response.

  • order_by (str) -- (Optional) Optional comma separated list of fields to order by, followed by asc or desc postfix.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

list[google.cloud.dlp_v2.types.StoredInfoType]

template_fields = ['organization_id', 'project_id', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPRedactImageOperator(*, project_id: Optional[str] = None, inspect_config: Optional[Union[Dict, InspectConfig]] = None, image_redaction_configs: Optional[Union[Dict, RedactImageRequest.ImageRedactionConfig]] = None, include_findings: Optional[bool] = None, byte_item: Optional[Union[Dict, ByteContentItem]] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Redacts potentially sensitive info from an image. This method has limits on input size, processing time, and output size.

See also

For more information on how to use this operator, take a look at the guide: Reference

Parameters

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. If set to None or missing, the default project_id from the Google Cloud connection is used.

  • inspect_config (dict or google.cloud.dlp_v2.types.InspectConfig) -- (Optional) Configuration for the inspector. Items specified here will override the template referenced by the inspect_template_name argument.

  • image_redaction_configs (list[dict] or list[google.cloud.dlp_v2.types.RedactImageRequest.ImageRedactionConfig]) -- (Optional) The configuration for specifying what content to redact from images.

  • include_findings (bool) -- (Optional) Whether the response should include findings along with the redacted image.

  • byte_item (dict or google.cloud.dlp_v2.types.ByteContentItem) -- (Optional) The content must be PNG, JPEG, SVG or BMP.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.RedactImageResponse

template_fields = ['project_id', 'inspect_config', 'image_redaction_configs', 'include_findings', 'byte_item', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPReidentifyContentOperator(*, project_id: Optional[str] = None, reidentify_config: Optional[Union[Dict, DeidentifyConfig]] = None, inspect_config: Optional[Union[Dict, InspectConfig]] = None, item: Optional[Union[Dict, ContentItem]] = None, inspect_template_name: Optional[str] = None, reidentify_template_name: Optional[str] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Re-identifies content that has been de-identified.

See also

For more information on how to use this operator, take a look at the guide: Re-identify Content

Parameters

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. If set to None or missing, the default project_id from the Google Cloud connection is used.

  • reidentify_config (dict or google.cloud.dlp_v2.types.DeidentifyConfig) -- (Optional) Configuration for the re-identification of the content item.

  • inspect_config (dict or google.cloud.dlp_v2.types.InspectConfig) -- (Optional) Configuration for the inspector.

  • item (dict or google.cloud.dlp_v2.types.ContentItem) -- (Optional) The item to re-identify. Will be treated as text.

  • inspect_template_name (str) -- (Optional) Optional template to use. Any configuration directly specified in inspect_config will override those set in the template.

  • reidentify_template_name (str) -- (Optional) Optional template to use. References an instance of DeidentifyTemplate. Any configuration directly specified in reidentify_config or inspect_config will override those set in the template.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.ReidentifyContentResponse

template_fields = ['project_id', 'reidentify_config', 'inspect_config', 'item', 'inspect_template_name', 'reidentify_template_name', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPUpdateDeidentifyTemplateOperator(*, template_id: str, organization_id: Optional[str] = None, project_id: Optional[str] = None, deidentify_template: Optional[Union[Dict, DeidentifyTemplate]] = None, update_mask: Optional[Union[Dict, FieldMask]] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Updates the DeidentifyTemplate.

See also

For more information on how to use this operator, take a look at the guide: De-Identification Template

Parameters

  • template_id (str) -- The ID of deidentify template to be updated.

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • deidentify_template (dict or google.cloud.dlp_v2.types.DeidentifyTemplate) -- New DeidentifyTemplate value.

  • update_mask (dict or google.cloud.dlp_v2.types.FieldMask) -- Mask to control which fields get updated.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.DeidentifyTemplate

template_fields = ['template_id', 'organization_id', 'project_id', 'deidentify_template', 'update_mask', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPUpdateInspectTemplateOperator(*, template_id: str, organization_id: Optional[str] = None, project_id: Optional[str] = None, inspect_template: Optional[Union[Dict, InspectTemplate]] = None, update_mask: Optional[Union[Dict, FieldMask]] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Updates the InspectTemplate.

See also

For more information on how to use this operator, take a look at the guide: Updating Template

Parameters

  • template_id (str) -- The ID of the inspect template to be updated.

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • inspect_template (dict or google.cloud.dlp_v2.types.InspectTemplate) -- New InspectTemplate value.

  • update_mask (dict or google.cloud.dlp_v2.types.FieldMask) -- Mask to control which fields get updated.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.InspectTemplate

template_fields = ['template_id', 'organization_id', 'project_id', 'inspect_template', 'update_mask', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPUpdateJobTriggerOperator(*, job_trigger_id, project_id: Optional[str] = None, job_trigger: Optional[JobTrigger] = None, update_mask: Optional[Union[Dict, FieldMask]] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Updates a job trigger.

See also

For more information on how to use this operator, take a look at the guide: Updating Job Trigger

Parameters

  • job_trigger_id (str) -- The ID of the DLP job trigger to be updated.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. If set to None or missing, the default project_id from the Google Cloud connection is used.

  • job_trigger (dict or google.cloud.dlp_v2.types.JobTrigger) -- New JobTrigger value.

  • update_mask (dict or google.cloud.dlp_v2.types.FieldMask) -- Mask to control which fields get updated.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.InspectTemplate

template_fields = ['job_trigger_id', 'project_id', 'job_trigger', 'update_mask', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]
class airflow.providers.google.cloud.operators.dlp.CloudDLPUpdateStoredInfoTypeOperator(*, stored_info_type_id, organization_id: Optional[str] = None, project_id: Optional[str] = None, config: Optional[Union[Dict, StoredInfoTypeConfig]] = None, update_mask: Optional[Union[Dict, FieldMask]] = None, retry: Optional[Retry] = None, timeout: Optional[float] = None, metadata: Optional[Sequence[Tuple[str, str]]] = None, gcp_conn_id: str = 'google_cloud_default', impersonation_chain: Optional[Union[str, Sequence[str]]] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Updates the stored infoType by creating a new version.

See also

For more information on how to use this operator, take a look at the guide: Update Stored Info-Type

Parameters

  • stored_info_type_id (str) -- The ID of the stored info type to be updated.

  • organization_id (str) -- (Optional) The organization ID. Required to set this field if parent resource is an organization.

  • project_id (str) -- (Optional) Google Cloud project ID where the DLP Instance exists. Only set this field if the parent resource is a project instead of an organization.

  • config (dict or google.cloud.dlp_v2.types.StoredInfoTypeConfig) -- Updated configuration for the storedInfoType. If not provided, a new version of the storedInfoType will be created with the existing configuration.

  • update_mask (dict or google.cloud.dlp_v2.types.FieldMask) -- Mask to control which fields get updated.

  • retry (google.api_core.retry.Retry) -- (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

  • timeout (float) -- (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (sequence[tuple[str, str]]]) -- (Optional) Additional metadata that is provided to the method.

  • gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud.

  • impersonation_chain (Union[str, Sequence[str]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

Return type

google.cloud.dlp_v2.types.StoredInfoType

template_fields = ['stored_info_type_id', 'organization_id', 'project_id', 'config', 'update_mask', 'gcp_conn_id', 'impersonation_chain'][source]
execute(self, context)[source]

Was this entry helpful?