dSrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SS K J r SSK J r S rS rS r\ R$\ R&"\ R(R*5"S S\ R,555r\ R0"SSS9\ R&"\ R(R25"SS\555rg)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 cH\rSrSrSr\\S.r\S5r \S5r Sr Sr g) CreateCzCreate a Datastream stream. DESCRIPTIONEXAMPLESc[R"USU5 [R"U5 [R"U5 [R "US5 [ R"U5 g)aCommon 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 CommonArgsCreate.CommonArgsIsP&&vxG$$V,**62$$VX6 v&c`[RU[RR5 gz@Args is called by calliope to gather arguments for this command.N)r rr ReleaseTrackGArs rArgs Create.Args[s  fd//223rcHURRR5nUR5R 5n[ R "5nURX2RUR5U5n[R"5n[R"5n[R"5nURSURURUR S9n UR"R%UR'U R(S95$)zCreate 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 streamsIdr!rGetClientInstanceGetMessagesModuleGetResourceParserr*r(r)projects_locations_operationsGet/DatastreamProjectsLocationsOperationsGetRequestr') selfargs stream_ref parent_ref stream_clientresult_operationclientmessagesresource_parser operation_refs rRun Create.Run`s%%++-J""$113J))+M$++J8L8L,0,=,=,?G # # %F%%'H,,.O#**2%**((** +,M  / / 3 3@@++ A - ..rN) __name__ __module__ __qualname____firstlineno____doc__rr detailed_help staticmethodrr$rB__static_attributes__rDrrr r Cs<$"-8D-''"44.rr FzdDatastream beta version is deprecated. Please use`gcloud datastream streams create` command instead.) is_removedwarningc2\rSrSrSr\\S.r\S5r Sr g) CreateBetazCreates a Datastream stream.rc`[RU[RR5 gr )r rrr!BETAr#s rr$CreateBeta.Argss  fd//445rrDN) rErFrGrHrIr EXAMPLES_BETArJrKr$rLrDrrrPrPs# %"-=I-66rrPN)rI __future__rrr!googlecloudsdk.api_lib.datastreamrrgooglecloudsdk.callioper%googlecloudsdk.command_lib.datastreamr r -googlecloudsdk.command_lib.datastream.streamsrrrrUDefaultUniverseOnly ReleaseTracksr!r"Commandr DeprecaterSrPrDrrr_s>&'52(7?P  ,  D%%(()9.T\\9.*9.x;=D%%**+66, = 6r