[(SrSSKJr SSKJr SSKJr SSKJr SSKJr SSK J r SSK J r S r S r S rS rS rS rSrSrSrSrSrS#SjrS$SjrS%SjrS&SjrSrS'SjrS#SjrS$SjrS%SjrS&Sjr S(Sjr!Sr"Sr#S)Sjr$S)Sjr%S r&S)S!jr'g")*z.Shared resource flags for Datastream commands.)absolute_import)division)unicode_literals)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", } ] } ] } } ``` 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 ConnectionProfileAttributeConfigrX&  2 2 ;!,f 5   c4[R"USSS0SS9$)Nz)The private connection of the {resource}.r r r rrrs r PrivateConnectionAttributeConfigr`rrc4[R"USSS0SS9$)NzThe stream of the {resource}.r r r rrrs rStreamAttributeConfigrhs&  2 2 /!,f 5   rc4[R"USSS0SS9$)NzThe route of the {resource}.r r r rrrs rRouteAttributeConfigrps&  2 2 .!,f 5   rc,[R"SSS9$)Nlocationz&The Cloud location for the {resource}.r rrrrLocationAttributeConfigr#xs  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 GetPrivateConnectionResourceSpecr3r0rc n[R"SU[US9[5[RSS9$)Nz%datastream.projects.locations.streamsrT)r% streamsIdr&r'r()rr)rr#r*r+s rGetStreamResourceSpecr6s5   -!%=9)+::"  $$rc [R"SU[US9[S5[ 5[R SS9$)Nz7datastream.projects.locations.privateConnections.routesrprivate-connectionT)r%routesIdr2r&r'r()rr)rrr#r*r+s rGetRouteResourceSpecr:s@   ?!#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@typedefaultrAr=z--forward-ssh-passwordz" SSH password. r@z--forward-ssh-private-keyzSSH private key..r8zprivate-connection-namezThe connection profile {}.rA--%sz&Resource ID of the private connection.r flag_name_overridesgroup --%s.location --locationcommand_level_fallthroughsN) add_group add_argumentr ReleaseTrackBETAintr ResourcePresentationSpecr/formatr3r ConceptParser AddToParser) parserverb release_track positionalrAr connectivity_parserforward_ssh_parserpassword_groupprivate_connection_flag_nameresource_specss rAddConnectionProfileResourceArgrcs  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=rAz --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.rFz--connection-profile-namez&Resource ID of the connection profile.r rIrJz"--connection-profile-name.locationrNrON)rQrRr rVr/rrXrY)rZconnection_profile_parserrbs r'AddConnectionProfileDiscoverResourceArgrfs %..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.r!rr"rrVpcAttributeConfig.GetVpcResourceSpec..VpcAttributeConfigs  4 4 P rzcompute.networksri)r%networkproject)rr)r*)rjs rGetVpcResourceSpecrns1    "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 {}.TrGN)r rVr3rWrrXrYrZr[r]r rbs rAddPrivateConnectionResourceArgrr+s_ D !D11  * , & - -d 3 .!k&)rc &URUS9nURUSS9nURSU[RR:Xa[ O[ S9 URSU[RR:Xa[O[S9 URSUS:Xa[O[S9 URS US:Xa[O[S9 URS US:Xa[O[S9 URS [S9 URUS9nURUSS9nURS S S9 URSSS9 SnSn U[RR:XaSnSn [ R""S[%5SR'U5SS9[ R""SU-[)5SUSS0US9[ R""SU -[)5SUSS0US9/n [*R,"U SU-S/SU -S/0S9R/U5 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. rGTrEz--oracle-source-configrFz--mysql-source-configz--postgresql-source-configupdatez--sqlserver-source-configz--salesforce-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 {}.rHz-Resource ID of the source connection profile.r rI)rArKrLz2Resource ID of the destination connection profile.rMrNrON)rQrRrrSrT$_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 _MONGODB_SOURCE_CONFIG_HELP_TEXTr rVr6rWr/rrXrY) rZr[r\rA source_parsersource_config_parser_groupdestination_parserdestination_config_parser_group source_fielddestination_fieldrbs rAddStreamResourceArgrFs""H"5-,66t 7 %))3@    4 /%D*F))2?    3 .%C*E))"   6 5 * ))!   5 4 * ))"   6 5 * )) +* ''':$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.TrGz--stream.locationrNrON)r rVr6rrXrY)rZrbs rAddStreamObjectResourceArgrsS11   ! + .  ~"  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 {}.TrGN)r rVr:rWrrXrYrqs rAddRouteResourceArgrs_ D D11     & .!k&)rN)r<)rp)rw)r)r )TT)T)(__doc__ __future__rrrgooglecloudsdk.callioper googlecloudsdk.calliope.conceptsr(googlecloudsdk.command_lib.util.conceptsrr rzr{rxryr}r|rr~rrrrrrrr#r,r/r3r6r:rcrfrnrrrrrr"rrrs5&'(5DG'#8"8($8#8.*>.*>-)@-)@.*2.*2$ <    K $$$$ $04-1 K\: 9$04*6dN(*r