ddZddlmZddlmZddlmZddlmZddlmZddlm Z ddl m Z dd l m Z ddl m Zd Zd Zd Ze j$e j&e j(j*Gd de j,Ze j0dde j&e j(j2GddeZy)z7Command to create connection profiles for a datastream.)absolute_import)division)unicode_literals)streams)util)base)flags) resource_argsz Create a Datastream stream. If successful, the response body contains a newly created instance of Operation. To get the operation result, call: describe OPERATION a To create a stream with an Oracle source and a Google Cloud Storage destination: $ {command} STREAM --location=us-central1 --display-name=my-stream --source=source --oracle-source-config=source_config.json --destination=destination --gcs-destination-config=destination_config.json --backfill-none To create a stream with a MySQL source and a Cloud Storage destination and that excludes some objects from being backfilled: $ {command} STREAM --location=us-central1 --display-name=my-stream --source=source --mysql-source-config=source_config.json --destination=destination --gcs-destination-config=destination_config.json --backfill-all --mysql-excluded-objects=excluded_objects.json To create a stream with an Oracle source and a BigQuery destination: $ {command} STREAM --location=us-central1 --display-name=my-stream --source=source --oracle-source-config=source_config.json --destination=destination --bigquery-destination-config=destination_config.json --backfill-none To create a stream with a PostgreSQL source and a BigQuery destination: $ {command} STREAM --location=us-central1 --display-name=my-stream --source=source --postgresql-source-config=source_config.json --destination=destination --bigquery-destination-config=destination_config.json --backfill-none To create a stream with a MongoDB source and a Cloud Storage destination and that excludes some objects from being backfilled: $ {command} STREAM --location=us-central1 --display-name=my-stream --source=source --mongodb-source-config=source_config.json --destination=destination --gcs-destination-config=destination_config.json --backfill-all --mongodb-excluded-objects=excluded_objects.json a To create a stream with an Oracle source and a Google Cloud Storage destination: $ {command} STREAM --location=us-central1 --display-name=my-stream --source-name=source --oracle-source-config=source_config.json --destination-name=destination --gcs-destination-config=destination_config.json --backfill-none To create a stream with a MySQL source and a Cloud Storage destination and that excludes some objects from being backfilled: $ {command} STREAM --location=us-central1 --display-name=my-stream --source-name=source --mysql-source-config=source_config.json --destination-name=destination --gcs-destination-config=destination_config.json --backfill-all --mysql-excluded-objects=excluded_objects.json c@eZdZdZeedZedZedZ dZ y)CreatezCreate a Datastream stream. DESCRIPTIONEXAMPLESctj|d|tj|tj|tj |dt j|y)a/Common arguments for all release tracks. Args: parser: An argparse parser that you can use to add arguments that go on the command line after this command. Positional arguments are allowed. release_track: Some arguments are added based on the command release track. creater N)r AddStreamResourceArg streams_flagsAddDisplayNameFlagAddBackfillStrategyGroupAddValidationGroupr AddLabelsCreateFlags)parser release_tracks (lib/surface/datastream/streams/create.py CommonArgszCreate.CommonArgsIsP&&vxG$$V,**62$$VX6 v&c`tj|tjjyz@Args is called by calliope to gather arguments for this command.N)r rr ReleaseTrackGArs rArgsz Create.Args[s  fd//223rcN|jjj}|jj }t j }|j||j|j|}tj}tj}tj}|jd|j|j|j } |j"j%|j'| j(S)aCreate a Datastream stream. Args: args: argparse.Namespace, The arguments that this command was invoked with. Returns: A dict object representing the operations resource describing the create operation if the create was successful. z(datastream.projects.locations.operations) operationsId projectsId locationsId)name)CONCEPTSstreamParseParent RelativeNamer StreamsClientr streamsIdrrGetClientInstanceGetMessagesModuleGetResourceParserr'r%r&projects_locations_operationsGet/DatastreamProjectsLocationsOperationsGetRequestr$) selfargs stream_ref parent_ref stream_clientresult_operationclientmessagesresource_parser operation_refs rRunz Create.Run`s%%++-J""$113J))+M$++J 8L8L,0,=,=,?G # # %F%%'H,,.O#**2%**((** +,M  / / 3 3@@++ A - ..rN) __name__ __module__ __qualname____doc__rr detailed_help staticmethodrr"r?rrr r Cs<$"-8D-''"44.rr FzdDatastream beta version is deprecated. Please use`gcloud datastream streams create` command instead.) is_removedwarningc*eZdZdZeedZedZy) CreateBetazCreates a Datastream stream.r c`tj|tjjyr)r rrrBETAr!s rr"zCreateBeta.Argss  fd//445rN) r@rArBrCr EXAMPLES_BETArDrEr"rFrrrJrJs# %"-=I-66rrJN)rC __future__rrr!googlecloudsdk.api_lib.datastreamrrgooglecloudsdk.callioper%googlecloudsdk.command_lib.datastreamr r -googlecloudsdk.command_lib.datastream.streamsrrrrMDefaultUniverseOnly ReleaseTracksrr Commandr DeprecaterLrJrFrrrWs>&'52(7?P  ,  D%%(()9.T\\9.*9.x;=D%%**+66, = 6r