tessl/pypi-google-cloud-dlp

Google Cloud Data Loss Prevention (DLP) API client library for discovering, classifying, and protecting sensitive data

—

Pending

Overview

Eval results

Files

Job Management

Name: tessl/pypi-google-cloud-dlp
Author: tessl

Long-running batch operations for processing large datasets, including scheduled triggers, hybrid content inspection, and comprehensive job lifecycle management for enterprise-scale data protection workflows.

Capabilities

DLP Job Operations

def create_dlp_job(
    request: dlp.CreateDlpJobRequest,
    *,
    parent: Optional[str] = None,
    inspect_job: Optional[dlp.InspectJobConfig] = None,
    risk_job: Optional[dlp.RiskAnalysisJobConfig] = None,
    retry: OptionalRetry = gapic_v1.method.DEFAULT,
    timeout: Union[float, object] = gapic_v1.method.DEFAULT,
    metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
) -> dlp.DlpJob: ...

def get_dlp_job(
    request: dlp.GetDlpJobRequest,
    *,
    name: Optional[str] = None,
    retry: OptionalRetry = gapic_v1.method.DEFAULT,
    timeout: Union[float, object] = gapic_v1.method.DEFAULT,
    metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
) -> dlp.DlpJob: ...

def list_dlp_jobs(
    request: dlp.ListDlpJobsRequest,
    *,
    parent: Optional[str] = None,
    retry: OptionalRetry = gapic_v1.method.DEFAULT,
    timeout: Union[float, object] = gapic_v1.method.DEFAULT,
    metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
) -> pagers.ListDlpJobsPager: ...

def delete_dlp_job(
    request: dlp.DeleteDlpJobRequest,
    *,
    name: Optional[str] = None,
    retry: OptionalRetry = gapic_v1.method.DEFAULT,
    timeout: Union[float, object] = gapic_v1.method.DEFAULT,
    metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
) -> None: ...

def cancel_dlp_job(
    request: dlp.CancelDlpJobRequest,
    *,
    retry: OptionalRetry = gapic_v1.method.DEFAULT,
    timeout: Union[float, object] = gapic_v1.method.DEFAULT,
    metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
) -> None: ...

def hybrid_inspect_dlp_job(
    request: dlp.HybridInspectDlpJobRequest,
    *,
    retry: OptionalRetry = gapic_v1.method.DEFAULT,
    timeout: Union[float, object] = gapic_v1.method.DEFAULT,
    metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
) -> dlp.HybridInspectResponse: ...

def finish_dlp_job(
    request: dlp.FinishDlpJobRequest,
    *,
    retry: OptionalRetry = gapic_v1.method.DEFAULT,
    timeout: Union[float, object] = gapic_v1.method.DEFAULT,
    metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
) -> None: ...

Job Trigger Operations

def create_job_trigger(
    request: dlp.CreateJobTriggerRequest,
    *,
    parent: Optional[str] = None,
    job_trigger: Optional[dlp.JobTrigger] = None,
    retry: OptionalRetry = gapic_v1.method.DEFAULT,
    timeout: Union[float, object] = gapic_v1.method.DEFAULT,
    metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
) -> dlp.JobTrigger: ...

def update_job_trigger(
    request: dlp.UpdateJobTriggerRequest,
    *,
    name: Optional[str] = None,
    job_trigger: Optional[dlp.JobTrigger] = None,
    update_mask: Optional[field_mask_pb2.FieldMask] = None,
    retry: OptionalRetry = gapic_v1.method.DEFAULT,
    timeout: Union[float, object] = gapic_v1.method.DEFAULT,
    metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
) -> dlp.JobTrigger: ...

def get_job_trigger(
    request: dlp.GetJobTriggerRequest,
    *,
    name: Optional[str] = None,
    retry: OptionalRetry = gapic_v1.method.DEFAULT,
    timeout: Union[float, object] = gapic_v1.method.DEFAULT,
    metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
) -> dlp.JobTrigger: ...

def list_job_triggers(
    request: dlp.ListJobTriggersRequest,
    *,
    parent: Optional[str] = None,
    retry: OptionalRetry = gapic_v1.method.DEFAULT,
    timeout: Union[float, object] = gapic_v1.method.DEFAULT,
    metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
) -> pagers.ListJobTriggersPager: ...

def delete_job_trigger(
    request: dlp.DeleteJobTriggerRequest,
    *,
    name: Optional[str] = None,
    retry: OptionalRetry = gapic_v1.method.DEFAULT,
    timeout: Union[float, object] = gapic_v1.method.DEFAULT,
    metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
) -> None: ...

def activate_job_trigger(
    request: dlp.ActivateJobTriggerRequest,
    *,
    retry: OptionalRetry = gapic_v1.method.DEFAULT,
    timeout: Union[float, object] = gapic_v1.method.DEFAULT,
    metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
) -> dlp.DlpJob: ...

def hybrid_inspect_job_trigger(
    request: dlp.HybridInspectJobTriggerRequest,
    *,
    retry: OptionalRetry = gapic_v1.method.DEFAULT,
    timeout: Union[float, object] = gapic_v1.method.DEFAULT,
    metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
) -> dlp.HybridInspectResponse: ...

Types

class DlpJob:
    """Long-running DLP operation."""
    
    name: str
    type_: DlpJobType
    state: DlpJob.JobState
    risk_details: AnalyzeDataSourceRiskDetails
    inspect_details: InspectDataSourceDetails
    create_time: timestamp_pb2.Timestamp
    start_time: timestamp_pb2.Timestamp
    end_time: timestamp_pb2.Timestamp
    last_modified: timestamp_pb2.Timestamp
    job_trigger_name: str
    errors: Sequence[Error]

class JobTrigger:
    """Scheduled DLP job configuration."""
    
    name: str
    display_name: str
    description: str
    inspect_job: InspectJobConfig
    triggers: Sequence[JobTrigger.Trigger]
    errors: Sequence[Error]
    create_time: timestamp_pb2.Timestamp
    update_time: timestamp_pb2.Timestamp
    last_run_time: timestamp_pb2.Timestamp
    status: JobTrigger.Status

class InspectJobConfig:
    """Configuration for inspection jobs."""
    
    storage_config: StorageConfig
    inspect_config: InspectConfig
    inspect_template_name: str
    actions: Sequence[Action]

class RiskAnalysisJobConfig:
    """Configuration for risk analysis jobs."""
    
    privacy_metric: PrivacyMetric
    source_table: BigQueryTable
    actions: Sequence[Action]

Install with Tessl CLI