&dZddlmZddlmZddlmZddlmZddlmZddl m Z ddl m Z dd lmZdd lmZdd lmZe j(e j*j,e j*j.Gd d e j0Zy)z8`gcloud dataplex datascans create data-profile` command.)absolute_import)division)unicode_literals)datascan)util) exceptions)base) resource_args) labels_util)logcXeZdZdZddiZedZejddZ y) DataProfilezCreate a Dataplex data profile scan job. Represents a user-visible job which provides the insights for the related data source about the structure, content and relationships (such as null percent, cardinality, min/max/mean, etc). EXAMPLESa To create a data profile scan `data-profile-datascan` in project `test-project` located in `us-central1` on bigquery resource table `test-table` in dataset `test-dataset`, run: $ {command} data-profile-datascan --project=test-project --location=us-central1 --data-source-resource="//bigquery.googleapis.com/projects/test-project/datasets/test-dataset/tables/test-table" ctj|d|jddd|jddd|jddd }|jd d |jdd |jdd}|jdd |jd }|jdd |jdd |jdd |jdd |jdd |jd }|jd d! |jdd"}|jd#td$%|jd&d' |jddd( }|jd)d*dd+,t j j|tj|y)-Nz"to create a data profile scan for.z --descriptionFz%Description of the data profile scan.)requiredhelpz--display-namez&Display name of the data profile scan.Tz&Data source for the data profile scan.)mutexrrz--data-source-entityzDataplex entity that contains the data for the data profile 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 profile scan, of the form: `//bigquery.googleapis.com/projects/{project_number}/datasets/{dataset_id}/tables/{table_id}`.z$Data spec for the data profile scan.)rrz--data-profile-spec-filezpath to the JSON/YAML file containing the spec for the data profile scan. The JSON representation reference: https://cloud.google.com/dataplex/docs/reference/rest/v1/DataProfileSpecz6Command line spec arguments for the data profile scan.z --row-filterz?A filter applied to all rows in a single data profile scan job.z--sampling-percentzTThe percentage of the records to be selected from the dataset for data profile scan.z--include-field-nameszNames of the fields to include in data profile. If not specified, all fields at the time of profile scan job execution are included. The fields listed in the `--exclude-field-names` flag are excluded.z--exclude-field-nameszNames of the fields to exclude from data profile. If specified, the respective fields will be excluded from data profile, regardless of the fields specified in the `--include-field-names` flag.z--export-results-tablezpath to the resource table to export data profile scan results, of the form: `//bigquery.googleapis.com/projects/{project_number}/datasets/{dataset_id}/tables/{table_id}`. The table will be created if not present.z%Data profile scan execution settings.z--incremental-fieldzRField that contains values that monotonically increase over time (e.g. timestamp).z2Data profile scan scheduling and trigger settings.z --on-demandzHIf set, the scan runs one-time shortly after data profile 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_source data_spec data_spec_argexecution_spectrigger async_groups 5lib/surface/dataplex/datascans/create/data_profile.pyArgszDataProfile.Args2s((4  4   5 "" 5#K  y  n   3!I" X'' E(M N " " -  9%% 3&N  ! &&M'G      C "" I#K  I   OO ,$$V,z-Status code: {status_code}. {status_message}.c *|jjj}t|ddt j }|j jt jj|j|jjtj|}t|ddr tj j#dyt|dd}|s\tj$|}tj&|j(dj+|j,|j. |Stj j#d j+||j(|S) N scan_typePROFILE) dataScanIdparentgoogleCloudDataplexV1DataScan validate_onlyFz1Validation completed. Skipping resource creation.async_z>Data profile scan created in project [{0}] with location [{1}])detailsz?Creating data profile scan with path [{0}] and operation [{1}].)CONCEPTSrParsesetattr dataplex_utilGetClientInstanceprojects_locations_dataScansCreateGetMessageModule/DataplexProjectsLocationsDataScansCreateRequestNameParent RelativeName GenerateDatascanForCreateRequestgetattrr statusPrintWaitForOperationCreatedResourcenameformat projectsId locationsId)selfargs datascan_refdataplex_client create_req_opr0responses r&RunzDataProfile.RunsF==))//1L D+y)#557O#@@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 CatchHTTPErrorRaiseHTTPExceptionrNr(r&rrsT -H-H-T5445""r(rN)rR __future__rrrgooglecloudsdk.api_lib.dataplexrrr5googlecloudsdk.api_lib.utilrrUgooglecloudsdk.callioper #googlecloudsdk.command_lib.dataplexr $googlecloudsdk.command_lib.util.argsr googlecloudsdk.corer ReleaseTracks ReleaseTrackALPHAGACommandrrWr(r&rdsr?&'4AF(=<#D%%++T->->-A-ABC$,,CCCr(