b SrSSKJr SSKJr SSKJr SSKJr SrSr Sr S r S r S r S rS rS rS rS rSrSrS"SjrS#SjrS$SjrS%SjrSrS&SjrS"SjrS#SjrS$SjrS%SjrS'SjrSr Sr!S(Sjr"S(Sjr#Sr$S(S jr%g!))z.Shared resource flags for Datastream commands.)base)concepts)concept_parsers)presentation_specsa Path to a YAML (or JSON) file containing the configuration for MySQL Source Config. The JSON file is formatted as follows, with snake_case field naming: ``` { "allowlist": {}, "rejectlist": { "mysql_databases": [ { "database_name":"sample_database", "mysql_tables": [ { "table_name": "sample_table", "mysql_columns": [ { "column_name": "sample_column", } ] } ] } ] } } ``` a{ Path to a YAML (or JSON) file containing the configuration for MySQL Source Config. The JSON file is formatted as follows, with camelCase field naming: ``` { "includeObjects": {}, "excludeObjects": { "mysqlDatabases": [ { "database":"sample_database", "mysqlTables": [ { "table": "sample_table", "mysqlColumns": [ { "column": "sample_column", } ] } ] } ] } } ``` aS Path to a YAML (or JSON) file containing the configuration for Oracle Source Config. The JSON file is formatted as follows, with snake_case field naming: ``` { "allowlist": {}, "rejectlist": { "oracle_schemas": [ { "schema_name": "SAMPLE", "oracle_tables": [ { "table_name": "SAMPLE_TABLE", "oracle_columns": [ { "column_name": "COL", } ] } ] } ] } } ``` aI Path to a YAML (or JSON) file containing the configuration for Oracle Source Config. The JSON file is formatted as follows, with camelCase field naming: ``` { "includeObjects": {}, "excludeObjects": { "oracleSchemas": [ { "schema": "SAMPLE", "oracleTables": [ { "table": "SAMPLE_TABLE", "oracleColumns": [ { "column": "COL", } ] } ] } ] } } ``` a Path to a YAML (or JSON) file containing the configuration for PostgreSQL Source Config. The JSON file is formatted as follows, with camelCase field naming: ``` { "includeObjects": {}, "excludeObjects": { "postgresqlSchemas": [ { "schema": "SAMPLE", "postgresqlTables": [ { "table": "SAMPLE_TABLE", "postgresqlColumns": [ { "column": "COL", } ] } ] } ] }, "replicationSlot": "SAMPLE_REPLICATION_SLOT", "publication": "SAMPLE_PUBLICATION" } ``` a Path to a YAML (or JSON) file containing the configuration for SQL Server Source Config. The JSON file is formatted as follows, with camelCase field naming: ``` { "includeObjects": {}, "excludeObjects": { "schemas": [ { "schema": "SAMPLE", "tables": [ { "table": "SAMPLE_TABLE", "columns": [ { "column": "COL", } ] } ] } ] }, "maxConcurrentCdcTasks": 2, "maxConcurrentBackfillTasks": 10, "transactionLogs": {} # Or changeTables } ``` a Path to a YAML (or JSON) file containing the configuration for Salesforce Source Config. The JSON file is formatted as follows, with camelCase field naming: ``` { "pollingInterval": "3000s", "includeObjects": {}, "excludeObjects": { "objects": [ { "objectName": "SAMPLE", "fields": [ { "fieldName": "SAMPLE_FIELD", } ] } ] } } ``` a0 Path to a YAML (or JSON) file containing the configuration for Spanner Source Config. The JSON file is formatted as follows, with camelCase field naming: ``` "changeStreamName": "SAMPLE_CHANGE_STREAM_NAME", { "includeObjects": {}, "excludeObjects": { "schemas": [ { "schema": "SAMPLE", "tables": [ { "table": "SAMPLE_TABLE", "columns": [ { "column": "COL", } ] } ] } ] }, "maxConcurrentCdcTasks": 1000, "maxConcurrentBackfillTasks": 10, "backfillDataBoostEnabled": false, "fgacRole": "SAMPLE_FGAC_ROLE", "spannerRpcPriority": "MEDIUM" } ``` a Path to a YAML (or JSON) file containing the configuration for Spanner Source Config. The JSON file is formatted as follows, with camelCase field naming: ``` { "includeObjects": {}, "excludeObjects": { "schemas": [ { "schema": "SAMPLE", "tables": [ { "table": "SAMPLE_TABLE", "columns": [ { "column": "COL", } ] } ] } ] }, "maxConcurrentCdcTasks": 1000, "maxConcurrentBackfillTasks": 10, "backfillDataBoostEnabled": false, "fgacRole": "SAMPLE_FGAC_ROLE", "spannerRpcPriority": "MEDIUM" } ``` aT Path to a YAML (or JSON) file containing the configuration for MongoDB Source Config. The JSON file is formatted as follows, with snake_case field naming: ``` { "includeObjects": {}, "excludeObjects": { "databases": [ { "database": "sampleDb", "collections": [ { "collection": "sampleCollection", "fields": [ { "field": "SAMPLE_FIELD", } ] } ] } ] } } ``` c4[R"USSS0SS9$)Nz)The connection profile of the {resource}. fieldMasknameidr help_textcompletion_request_paramscompletion_id_fieldr ResourceParameterAttributeConfigr s :lib/googlecloudsdk/command_lib/datastream/resource_args.py ConnectionProfileAttributeConfigr&  2 2 ;!,f 5   c4[R"USSS0SS9$)Nz)The private connection of the {resource}.rr r r rrs r PrivateConnectionAttributeConfigrrrc4[R"USSS0SS9$)NzThe stream of the {resource}.rr r r rrs rStreamAttributeConfigrs&  2 2 /!,f 5   rc4[R"USSS0SS9$)NzThe route of the {resource}.rr r r rrs rRouteAttributeConfigrs&  2 2 .!,f 5   rc,[R"SSS9$)Nlocationz&The Cloud location for the {resource}.r r rrrLocationAttributeConfigr s  2 2 !I KKrc^[R"SU[5[RSS9$)Nzdatastream.projects.locationsT) resource_name locationsId projectsIddisable_auto_completers)r ResourceSpecr DEFAULT_PROJECT_ATTRIBUTE_CONFIGr"s rGetLocationResourceSpecr)s-   %!)+::"  $$rc n[R"SU[US9[5[RSS9$)Nz0datastream.projects.locations.connectionProfilesrT)r"connectionProfilesIdr#r$r%)rr&rr r'r(s r GetConnectionProfileResourceSpecr,5   8!;O)+::"  $$rc n[R"SU[US9[5[RSS9$)Nz0datastream.projects.locations.privateConnectionsrT)r"privateConnectionsIdr#r$r%)rr&rr r'r(s r GetPrivateConnectionResourceSpecr0r-rc n[R"SU[US9[5[RSS9$)Nz%datastream.projects.locations.streamsrT)r" streamsIdr#r$r%)rr&rr r'r(s rGetStreamResourceSpecr3s5   -!%=9)+::"  $$rc [R"SU[US9[S5[ 5[R SS9$)Nz7datastream.projects.locations.privateConnections.routesrprivate-connectionT)r"routesIdr/r#r$r%)rr&rrr r'r(s rGetRouteResourceSpecr7s@   ?!#7;  )+::" $$rc U(aSnOSnURSS9nURSSSS9 U[RR:XaURS SS S9 UR5nURS S US 9 URSSUS 9 URSS[ SS9 URUSS9nURSSS9 URSSS9 Sn U[RR:XaSn [ R"U[5SRU5SS9[ R"SU -[5SS S!0US"9/n [R"U S#U -S$/0S%9RU5 g&)'aAdd a resource argument for a Datastream connection profile. Args: parser: the parser for the command. verb: str, the verb to describe the resource, such as 'to update'. release_track: Some arguments are added based on the command release track. positional: bool, if True, means that the resource is a positional rather than a flag. required: bool, if True, means that a flag is required. connection_profilez--connection-profileT)mutexz--static-ip-connectivity store_truezuse static ip connectivity)actionhelpz--no-connectivityzno connectivityz--forward-ssh-hostnamezHostname for the SSH tunnel.)r=requiredz--forward-ssh-usernamezUsername for the SSH tunnel.z--forward-ssh-portz-Port for the SSH tunnel, default value is 22.)r=typedefaultr>r:z--forward-ssh-passwordz" SSH password. r=z--forward-ssh-private-keyzSSH private key..r5zprivate-connection-namezThe connection profile {}.r>--%sz&Resource ID of the private connection.rflag_name_overridesgroup --%s.location --locationcommand_level_fallthroughsN) add_group add_argumentr ReleaseTrackBETAintrResourcePresentationSpecr,formatr0r ConceptParser AddToParser) parserverb release_track positionalr>r connectivity_parserforward_ssh_parserpassword_groupprivate_connection_flag_nameresource_specss rAddConnectionProfileResourceArgr`s  D !D((t(4""  +#- d'',,,$$L7L%N+446!! -"!! -"!! >  " &///N.&!(;="6d'',,,#< 11  * , & - -d 3  11 / / * , 2)2.# % . 8 8<."  V rcURSSS9nURSSS9 [R"S[ 5SSS 0US 9/n[ R "US S /0S 9RU5 g)z{Add a resource argument for a Datastream connection profile discover command. Args: parser: the parser for the command. T)r:r>z --connection-profile-object-filezPath to a YAML (or JSON) file containing the configuration for a connection profile object. If you pass - as the value of the flag the file content will be read from stdin.rCz--connection-profile-namez&Resource ID of the connection profile.rrFrGz"--connection-profile-name.locationrKrLN)rNrOrrSr,rrUrV)rWconnection_profile_parserr_s r'AddConnectionProfileDiscoverResourceArgrc@s %..TD.I((( 8)11 % * , 2)2.) +. ."  V rc\Sn[R"SSU"5[RS9$)z:Constructs and returns the Resource specification for VPC.c,[R"SSS9$)Nvpcz8fully qualified name of the VPC Datastream will peer to.rrrrrVpcAttributeConfig.GetVpcResourceSpec..VpcAttributeConfig`s  4 4 P rzcompute.networksrf)r"networkproject)rr&r')rgs rGetVpcResourceSpecrk]s1    "77  99rcU(aSnOSn[R"U[5SRU5SS9/n[R "U5R U5 g)a Add a resource argument for a Datastream private connection. Args: parser: the parser for the command. verb: str, the verb to describe the resource, such as 'to update'. positional: bool, if True, means that the resource is a positional rather than a flag. private_connectionz--private-connectionzThe private connection {}.TrDN)rrSr0rTrrUrVrWrXrZr r_s rAddPrivateConnectionResourceArgroms_ D !D11  * , & - -d 3 .!k&)rc fURUS9nURUSS9nURSU[RR:Xa[ O[ S9 URSU[RR:Xa[O[S9 URSUS:Xa[O[S9 URS US:Xa[O[S9 URS US:Xa[O[S9 URS US:Xa[O[ S9 URS ["S9 URUS9nURUSS9nURS SS9 URSSS9 SnSn U[RR:XaSnSn [$R&"S[)5SR+U5SS9[$R&"SU-[-5SUSS0US9[$R&"SU -[-5SUSS0US9/n [.R0"U SU-S/SU -S/0S9R3U5 g )!acAdd resource arguments for creating/updating a stream. Args: parser: argparse.ArgumentParser, the parser for the command. verb: str, the verb to describe the resource, such as 'to update'. release_track: base.ReleaseTrack, some arguments are added based on the command release track. required: bool, if True, means that a flag is required. rDTrBz--oracle-source-configrCz--mysql-source-configz--postgresql-source-configupdatez--sqlserver-source-configz--salesforce-source-configz--spanner-source-configz--mongodb-source-configz--gcs-destination-configaC Path to a YAML (or JSON) file containing the configuration for Google Cloud Storage Destination Config. The JSON file is formatted as follows: ``` { "path": "some/path", "fileRotationMb":5, "fileRotationInterval":"15s", "avroFileFormat": {} } ``` z--bigquery-destination-configa Path to a YAML (or JSON) file containing the configuration for Google BigQuery Destination Config. The YAML (or JSON) file should be formatted as follows: BigQuery configuration with source hierarchy datasets and merge mode (merge mode is by default): ``` { "sourceHierarchyDatasets": { "datasetTemplate": { "location": "us-central1", "datasetIdPrefix": "my_prefix", "kmsKeyName": "projects/{project}/locations/{location}/keyRings/{key_ring}/cryptoKeys/{cryptoKey}" } }, "merge": {} "dataFreshness": "3600s" } ``` BigQuery configuration with source hierarchy datasets and append only mode: ``` { "sourceHierarchyDatasets": { "datasetTemplate": { "location": "us-central1", "datasetIdPrefix": "my_prefix", "kmsKeyName": "projects/{project}/locations/{location}/keyRings/{key_ring}/cryptoKeys/{cryptoKey}" } }, "appendOnly": {} } ``` BigQuery configuration with single target dataset and merge mode: ``` { "singleTargetDataset": { "datasetId": "projectId:my_dataset" }, "merge": {} "dataFreshness": "3600s" } ``` BigQuery configuration with Big Lake table configuration: ``` { "singleTargetDataset": { "datasetId": "projectId:datasetId" }, "appendOnly": {}, "blmtConfig": { "bucket": "bucketName", "tableFormat": "ICEBERG", "fileFormat": "PARQUET", "connectionName": "projectId.region.connectionName", "rootPath": "/root" } } ``` source destinationz source-namezdestination-namestreamzThe stream to {}.rEz-Resource ID of the source connection profile.rrF)r>rHrIz2Resource ID of the destination connection profile.rJrKrLN)rNrOrrPrQ$_ORACLE_SOURCE_CONFIG_HELP_TEXT_BETA_ORACLE_SOURCE_CONFIG_HELP_TEXT#_MYSQL_SOURCE_CONFIG_HELP_TEXT_BETA_MYSQL_SOURCE_CONFIG_HELP_TEXT*_POSTGRESQL_UPDATE_SOURCE_CONFIG_HELP_TEXT*_POSTGRESQL_CREATE_SOURCE_CONFIG_HELP_TEXT)_SQLSERVER_UPDATE_SOURCE_CONFIG_HELP_TEXT)_SQLSERVER_CREATE_SOURCE_CONFIG_HELP_TEXT*_SALESFORCE_UPDATE_SOURCE_CONFIG_HELP_TEXT*_SALESFORCE_CREATE_SOURCE_CONFIG_HELP_TEXT'_SPANNER_UPDATE_SOURCE_CONFIG_HELP_TEXT'_SPANNER_CREATE_SOURCE_CONFIG_HELP_TEXT _MONGODB_SOURCE_CONFIG_HELP_TEXTrrSr3rTr,rrUrV) rWrXrYr> source_parsersource_config_parser_groupdestination_parserdestination_config_parser_group source_fielddestination_fieldr_s rAddStreamResourceArgrs""H"5-,66t 7 %))3@    4 /%D*F))2?    3 .%C*E))"   6 5 * ))!   5 4 * ))"   6 5 * ))   3 2 * )) +* ''':$6$@$@t%A%%!!..  /""..%? /BH,#d'',,, L*11   !  $ $T *  11 <  * , 9)2. 11 $ $ * , >)2." $.* L (<. - - ~" V rc[R"S[5SSS9/n[R"USS/0S9R U5 g) zeAdd a resource argument for a Datastream stream object. Args: parser: the parser for the command. z--streamzThe stream to list objects for.TrDz--stream.locationrKrLN)rrSr3rrUrV)rWr_s rAddStreamObjectResourceArgr5sS11   ! + .  ~"  V rcU(aSnOSn[R"U[5SRU5SS9/n[R "U5R U5 g)zAdd a resource argument for a Datastream route. Args: parser: the parser for the command. verb: str, the verb to describe the resource, such as 'to create'. positional: bool, if True, means that the resource is a positional rather than a flag. routez--routez The route {}.TrDN)rrSr7rTrrUrVrns rAddRouteResourceArgrIs_ D D11     & .!k&)rN)r9)rm)rt)r)r)TT)T)&__doc__googlecloudsdk.callioper googlecloudsdk.calliope.conceptsr(googlecloudsdk.command_lib.util.conceptsrrrwrxrurvrzryr|r{r~r}rrrrrrrr r)r,r0r3r7r`rcrkrorrrrrrrs5)5DG'#8"8($8#8.*>.*>-)@-)@.*2.*2!+'F +'D$ <    K $$$$ $04-1 K\: 9$04*6jZ(*r