DdZddlmZddlmZddlmZddlmZddlmZddl m Z ddl m Z dd lmZdd lmZdd lmZe j(e j*j,e j*j.e j0Gd d e j2Zy)z8`gcloud dataplex datascans create data-quality` command.)absolute_import)division)unicode_literals)datascan)util) exceptions)base) resource_args) labels_util)logcXeZdZdZddiZedZejddZ y) DataQualityzCreate a Dataplex data quality scan job. Represents a user-visible job which provides the insights for the related data source and generates queries based on the rules and runs against the data to get data quality check results. EXAMPLESa To create a data quality scan `data-quality-datascan` in project `test-project` located in `us-central1` on bigquery resource table `test-table` in dataset `test-dataset` with data spec file `data-quality-spec.json`, run: $ {command} data-quality-datascan --project=test-project --location=us-central1 --data-source-resource="//bigquery.googleapis.com/projects/test-project/datasets/test-dataset/tables/test-table" --data-quality-spec-file="data-quality-spec.json" ctj|d|jddd|jddd|jddd }|jd d |jdd |jddd|jd }|jdd |jdd}|jdtd|jdd |jddd }|jdddd t j j|tj|y)!Nz"to create a data quality scan for.z --descriptionFz%Description of the data quality scan.)requiredhelpz--display-namez&Display name of the data quality scan.Tz&Data source for the data quality scan.)mutexrrz--data-source-entityzDataplex entity that contains the data for the data quality scan, of the form: `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/entities/{entity_id}`.)rz--data-source-resourcezFully-qualified service resource name of the cloud resource that contains the data for the data quality scan, of the form: `//bigquery.googleapis.com/projects/{project_number}/datasets/{dataset_id}/tables/{table_id}`.z--data-quality-spec-filea.Path to the JSON/YAML file containing the spec for the data quality scan. The JSON representation reference: https://cloud.google.com/dataplex/docs/reference/rest/v1/DataQualitySpec The YAML representation reference: https://cloud.google.com/dataplex/docs/use-auto-data-quality#create-scan-using-gcloudz%Data quality scan execution settings.z--incremental-fieldzRField that contains values that monotonically increase over time (e.g. timestamp).z1Data quality scan scheduling and trigger settings)rrz --on-demandzHIf set, the scan runs one-time shortly after data quality scan creation.)typerz --scheduleaCron schedule (https://en.wikipedia.org/wiki/Cron) for running scans periodically. To explicitly set a timezone to the cron tab, apply a prefix in the cron tab: "CRON_TZ=${IANA_TIME_ZONE}" or "TZ=${IANA_TIME_ZONE}". The ${IANA_TIME_ZONE} may only be a valid string from IANA time zone database. For example, `CRON_TZ=America/New_York 1 * * * *` or `TZ=America/New_York 1 * * * *`. This field is required for RECURRING scans.z:At most one of --async | --validate-only can be specified.z--validate-only store_truez:Validate the create action, but don't actually perform it.)actiondefaultr) r AddDatascanResourceArg add_argument add_groupboolr ASYNC_FLAG AddToParserr AddCreateLabelsFlags)parser data_sourceexecution_spectrigger async_groups 5lib/surface/dataplex/datascans/create/data_quality.pyArgszDataQuality.Args2s((4  4   5 ""T(P#K y  n " e  %% 3&N  ! &&L'G      C "" I#K  I   OO ,$$V,z-Status code: {status_code}. {status_message}.c *|jjj}tj}t |dd|j jtjj|j|jjtj|}t|ddr tj j#dyt|dd}|s\tj$|}tj&|j(dj+|j,|j. |Stj j#d j+||j(|S) N scan_typeQUALITY) dataScanIdparentgoogleCloudDataplexV1DataScan validate_onlyFz1Validation completed. Skipping resource creation.async_z>Data quality scan created in project [{0}] with location [{1}])detailsz?Creating Data quality scan with path [{0}] and operation [{1}].)CONCEPTSrParse dataplex_utilGetClientInstancesetattrprojects_locations_dataScansCreateGetMessageModule/DataplexProjectsLocationsDataScansCreateRequestNameParent RelativeName GenerateDatascanForCreateRequestgetattrr statusPrintWaitForOperationCreatedResourcenameformat projectsId locationsId)selfargs datascan_refdataplex_client create_req_opr.responses r$RunzDataQuality.RunsF==))//1L#557O D+y)#@@GG&&(XX#((*&&(557*2*S*S+ Y Mt_e, jjJK T8U +F **=9h  --Nvl--|/G/GH oJJI  m00 1 r&N) __name__ __module__ __qualname____doc__ detailed_help staticmethodr%gcloud_exception CatchHTTPErrorRaiseHTTPExceptionrLr&r$rrsT-]-]-~5445""r&rN)rP __future__rrrgooglecloudsdk.api_lib.dataplexrrr2googlecloudsdk.api_lib.utilrrSgooglecloudsdk.callioper #googlecloudsdk.command_lib.dataplexr $googlecloudsdk.command_lib.util.argsr googlecloudsdk.corer ReleaseTracks ReleaseTrackALPHAGAUniverseCompatibleCommandrrUr&r$rcs?&'4AF(=<#D%%++T->->-A-ABW$,,WCWr&