XdZddlmZddlmZddlmZddlmZddlmZddl m Z dd d Z ejejjGd d ejZe e_y )z'trace sinks create command.)absolute_import)division)unicode_literals)util)base)loga0 Creates a sink used to export trace spans to a destination. The sink's destination must be a BigQuery dataset. The destination must already exist. The identity created with the sink will need permission to write to the destination dataset. After creating a sink look for the *[writer_identity]* to be populated in the response. With that identity run the following command to give it permission: gcloud projects add-iam-policy-binding {bigquery_project_id} \ --member serviceAccount:{writer_identity from trace_sink} \ --role roles/bigquery.dataEditor You may also find an existing writer identity by describing a sink. It may take several minutes before trace spans are exported after the sink is created. zg $ {command} my-sink bigquery.googleapis.com/projects/my-project/datasets/my_dataset ) DESCRIPTIONEXAMPLESc&eZdZdZedZdZy)CreatezCreates a sink.c|jdd|jdd|jdd|jjdy) z Register flags for this command. sink_namezThe name for the sink.)help destinationzThe destination must be a fully qualified BigQuery resource name. The destination can be for the same Google Cloud project or for a different Google Cloud project in the same organization.z --projectzSCreate a sink associated with this project. This will override the default project.N) add_argument display_infoAddCacheUpdater)parsers !lib/surface/trace/sinks/create.pyArgsz Create.Args;sh  *BC DE  34 ''-c htj|j|jj }|d|j id}tj jjtjjtj|jj tjjdi|}tjjdj!|j"tj$|S)zThis is what gets called when the user runs this command. Args: args: an argparse namespace. All the arguments that were provided to this command invocation. Returns: The created sink with its destination. r)name outputConfig)parent traceSinkzYou can give permission to the service account by running the following command. gcloud projects add-iam-policy-binding bigquery-project \ --member serviceAccount:{0} \ --role roles/bigquery.dataEditor)rGetTraceSinkResourcerproject RelativeNamer GetClientprojects_traceSinksr GetMessages)CloudtraceProjectsTraceSinksCreateRequestGetProjectResource TraceSinkrstatusPrintformatwriterIdentityFormatTraceSink)selfargssink_resource_name sink_data result_sinks rRunz Create.RunJs224>>37<<AAM# 4++ I.."66== DD**4<<8EEG2d&&(22?Y? E ABK JJ $%+F;+E+E$F H    ,,rN)__name__ __module__ __qualname____doc__ staticmethodrr1rrrr r 5s  . .-rr N)r5 __future__rrrgooglecloudsdk.api_lib.tracergooglecloudsdk.calliopergooglecloudsdk.corer DETAILED_HELP ReleaseTracks ReleaseTrackALPHA CreateCommandr detailed_helprrrrAsr#&'-(# & + 8D%%++,3-T  3--3-l%r