%VdZddlmZddlmZddlmZddlmZddlmZddlm Z ddl m Z dd l m Z e je je j j"e j j$e j j&Gd d e j(Zy ) z'logging sinks create' command.)absolute_import)division)unicode_literals)util) arg_parsers)base)log) console_ioc8eZdZdZedZdZdZdZdZ y)CreateaCreate a log sink. Create a log sink used to route log entries to a destination. The sink routes all log entries that match its *--log-filter* flag. An empty filter matches all logs. Detailed information about filters can be found at: [](https://cloud.google.com/logging/docs/view/logging-query-language) The sink's destination can be a Cloud Logging log bucket, a Cloud Storage bucket, a BigQuery dataset, a Cloud Pub/Sub topic, or a Google Cloud project. The destination must already exist. If creating a log sink to route logs to a destination outside of Cloud Logging or to a Cloud Logging log bucket in another project, the log sink's service account must be granted permission to write to the destination. For more information about destination permissions, see: https://cloud.google.com/logging/docs/export/configure_export_v2#dest-auth Matching log entries are routed to the destination after the sink is created. ## EXAMPLES To route all Google Compute Engine logs to BigQuery, run: $ {command} my-bq-sink bigquery.googleapis.com/projects/my-project/datasets/my_dataset --log-filter='resource.type="gce_instance"' To route "syslog" from App Engine Flexible to a Cloud Storage bucket, run: $ {command} my-gcs-sink storage.googleapis.com/my-bucket --log-filter='logName="projects/my-project/appengine.googleapis.com%2Fsyslog"' To route Google App Engine logs with ERROR severity, run: $ {command} my-error-logs bigquery.googleapis.com/projects/my-project/datasets/my_dataset --log-filter='resource.type="gae_app" AND severity=ERROR' To route all logs to a log bucket in a different project, run: $ {command} my-sink logging.googleapis.com/projects/my-central-project/locations/global/buckets/my-central-bucket To route all logs to another project, run: $ {command} my-sink logging.googleapis.com/projects/my-destination-project c |jdd|jdtjdd|jdd d |jd d d d|jdd d d|jddd|jd}|jdd d d|jddtjt t t t dddgd |jd!d"|jd#d d$%tj|d&|jjd'y')(z Register flags for this command. sink_namezThe name for the sink.)help destinationzThe destination for the sink.z*Some destination types are not supported .)default universe_helpz --log-filterFz_A filter expression for the sink. If present, the filter specifies which log entries to export.)requiredrz--include-children store_truezpWhether to export logs from all child projects and folders. Only applies to sinks for organizations and folders.)ractionrz--intercept-childrenzsWhether to intercept logs from all child projects and folders. Only applies to sinks for organizations and folders.z--custom-writer-identitySERVICE_ACCOUNT_EMAILzWriter identity for the sink. This flag can only be used if the destination is a log bucket in a different project. The writer identity is automatically generated when it is not provided for a sink.)metavarrz-Settings for sink exporting data to BigQuery.z--use-partitioned-tablesa(If specified, use BigQuery's partitioned tables. By default, Logging creates dated tables based on the log entries' timestamps, e.g. 'syslog_20170523'. Partitioned tables remove the suffix and special query syntax (https://cloud.google.com/bigquery/docs/querying-partitioned-tables) must be used.z --exclusionappend)name descriptionfilterdisabledrr)spec required_keysaDSpecify an exclusion filter for a log entry that is not to be exported. This flag can be repeated. The ``name'' and ``filter'' attributes are required. The following keys are accepted: *name*::: An identifier, such as ``load-balancer-exclusion''. Identifiers are limited to 100 characters and can include only letters, digits, underscores, hyphens, and periods. *description*::: A description of this exclusion. *filter*::: An advanced log filter that matches the log entries to be excluded. *disabled*::: If this exclusion should be disabled and not exclude the log entries.)rtyperz --descriptionzDescription of the sink.z --disabledz9Sink will be disabled. Disabled sinks do not export logs.)rrzsink to createN) add_argumentrUniverseHelpTextadd_argument_groupArgDictstrboolr AddParentArgs display_infoAddCacheUpdater)parserbigquery_groups #lib/surface/logging/sinks/create.pyArgsz Create.ArgsVs  *BC   ) )3G  79  E G   C  "'   .. </>N";  =   "  "8,. )+0 .HI IL  v/0 ''-c tj}tjjj |j ||j di|d|S)z-Creates a v2 sink specified by the arguments.T)parentlogSinkuniqueWriterIdentitycustomWriterIdentity)r GetMessages GetClientprojects_sinksr !LoggingProjectsSinksCreateRequestLogSink)selfr/ sink_datacustom_writer_identitymessagess r+ CreateSinkzCreate.CreateSinks_!H >>  * * 1 122$H$$1y1!%!7 3 9 ::r-c8|jstjdd|jsN|jsB|j rt jd|jrt jdtj|j|}|j|jd}|jdr|j |d<|jd r|j|d <|jd r|j|d <|jd ri}|j|d<||d<|jdr|j |d<|jdr|j"|d<|jdr|j$|d<d}|jdr |j&}|j)tj*|||}t j,||j|_|j0|_|S)Nz+Sink with empty filter matches all entries.T) cancel_on_nozQinclude-children only has an effect for sinks at the folder or organization levelzSintercept-children only has an effect for sinks at the folder or organization level)rrinclude_childrenincludeChildrenintercept_childreninterceptChildren log_filterruse_partitioned_tablesusePartitionedTablesbigqueryOptions exclusion exclusionsrrr;)rDr PromptContinue organizationfolderr@r warningrBrGetSinkReferencersinksIdr IsSpecifiedrErHrrr;r=GetParentFromArgsCreatedResource_epilog_result_destinationwriterIdentity_epilog_writer_identity)r9argssink_refr:bigquery_optionsr;results r+_Runz Create._Runs ?? 7dL       $     $ $$T^^T:H  ''I  *+%)%:%:i!" ,-'+'>'>i#$  % OOi 01151L1L-.%5i!"  $ $i   &!%!1!1i   #"mmi ! 01#:: __ t$i1GIF!&,&8&8D##)#8#8D Mr-c$|j|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. )rZ)r9rVs r+Runz Create.Runs 99T?r-cXtj|j|jy)N)rPrintPermissionInstructionsrSrU)r9unused_resources_were_displayeds r+Epilogz Create.Epilogs"$$T%D%D%)%A%ACr-N) __name__ __module__ __qualname____doc__ staticmethodr,r=rZr\r`r3r-r+r r s5 1hT.T.l:9v Cr-r N)rd __future__rrrgooglecloudsdk.api_lib.loggingrgooglecloudsdk.callioperrgooglecloudsdk.corer googlecloudsdk.core.consoler UniverseCompatible ReleaseTracks ReleaseTrackGABETAALPHA CreateCommandr r3r-r+rrs&&'//(#2$++00$2C2C2I2I`CT  `C`Cr-