Update a sink

  private 
  
 void 
  
 UpdateSinkLog 
 ( 
 string 
  
 sinkId 
 , 
  
 string 
  
 logId 
 ) 
 { 
  
 var 
  
 sinkClient 
  
 = 
  
 ConfigServiceV2Client 
 . 
 Create 
 (); 
  
 LogName 
  
 logName 
  
 = 
  
 new 
  
 LogName 
 ( 
 s_projectId 
 , 
  
 logId 
 ); 
  
 LogSinkName 
  
 sinkName 
  
 = 
  
 new 
  
 LogSinkName 
 ( 
 s_projectId 
 , 
  
 sinkId 
 ); 
  
 var 
  
 sink 
  
 = 
  
 sinkClient 
 . 
 GetSink 
 ( 
 sinkName 
 , 
  
 _retryAWhile 
 ); 
  
 sink 
 . 
 Filter 
  
 = 
  
 $"logName={logName.ToString()}AND severity<=ERROR" 
 ; 
  
 sinkClient 
 . 
 UpdateSink 
 ( 
 sinkName 
 , 
  
 sink 
 , 
  
 _retryAWhile 
 ); 
  
 Console 
 . 
 WriteLine 
 ( 
 $"Updated {sinkId} to export logs from {logId}." 
 ); 
 } 
 

  import 
  
 ( 
  
 "context" 
  
 "log" 
  
 "cloud.google.com/go/logging/logadmin" 
 ) 
 func 
  
 updateSink 
 ( 
 projectID 
  
 string 
 ) 
  
 ( 
 * 
 logadmin 
 . 
 Sink 
 , 
  
 error 
 ) 
  
 { 
  
 ctx 
  
 := 
  
 context 
 . 
 Background 
 () 
  
 client 
 , 
  
 err 
  
 := 
  
 logadmin 
 . 
  NewClient 
 
 ( 
 ctx 
 , 
  
 projectID 
 ) 
  
 if 
  
 err 
  
 != 
  
 nil 
  
 { 
  
 log 
 . 
 Fatalf 
 ( 
 "logadmin.NewClient: %v" 
 , 
  
 err 
 ) 
  
 } 
  
 defer 
  
 client 
 . 
  Close 
 
 () 
  
 sink 
 , 
  
 err 
  
 := 
  
 client 
 . 
  UpdateSink 
 
 ( 
 ctx 
 , 
  
& logadmin 
 . 
 Sink 
 { 
  
 ID 
 : 
  
 "severe-errors-to-gcs" 
 , 
  
 Destination 
 : 
  
 "storage.googleapis.com/logsinks-new-bucket" 
 , 
  
 Filter 
 : 
  
 "severity >= INFO" 
 , 
  
 }) 
  
 return 
  
 sink 
 , 
  
 err 
 } 
 

  SinkInfo 
  
 sinkInfo 
  
 = 
  
 SinkInfo 
 . 
 newBuilder 
 ( 
 sinkName 
 , 
  
 DatasetDestination 
 . 
 of 
 ( 
 datasetName 
 )) 
  
 . 
 setVersionFormat 
 ( 
 SinkInfo 
 . 
 VersionFormat 
 . 
 V2 
 ) 
  
 . 
 setFilter 
 ( 
 "severity>=ERROR" 
 ) 
  
 . 
 build 
 (); 
 Sink 
  
 sink 
  
 = 
  
 logging 
 . 
 update 
 ( 
 sinkInfo 
 ); 
 

  // Imports the Google Cloud client library 
 const 
  
 { 
 Logging 
 } 
  
 = 
  
 require 
 ( 
 ' @google-cloud/logging 
' 
 ); 
 // Creates a client 
 const 
  
 logging 
  
 = 
  
 new 
  
  Logging 
 
 (); 
 /** 
 * TODO(developer): Uncomment the following lines to run the code. 
 */ 
 // const sinkName = 'Name of sink to update, e.g. my-sink'; 
 // const filter = 'New filter for the sink, e.g. severity >= WARNING'; 
 const 
  
 sink 
  
 = 
  
 logging 
 . 
 sink 
 ( 
 sinkName 
 ); 
 /** 
 * The filter determines which logs this sink matches and will be exported 
 * to the destination. For example a filter of 'severity>=INFO' will send 
 * all logs that have a severity of INFO or greater to the destination. 
 * See https://cloud.google.com/logging/docs/view/advanced_filters for more 
 * filter information. 
 */ 
 const 
  
 metadataInfo 
  
 = 
  
 { 
  
 filter 
 : 
  
 filter 
 , 
 }; 
 async 
  
 function 
  
 updateSink 
 () 
  
 { 
  
 // See https://googleapis.dev/nodejs/logging/latest/Sink.html#setMetadata 
  
 const 
  
 [ 
 metadata 
 ] 
  
 = 
  
 await 
  
 sink 
 . 
  setMetadata 
 
 ( 
 metadataInfo 
 ); 
  
 console 
 . 
 log 
 ( 
 `Sink 
 ${ 
 sinkName 
 } 
 updated.` 
 , 
  
 metadata 
 ); 
 } 
 updateSink 
 (); 
 

  use Google\Cloud\Logging\LoggingClient; 
 /** 
 * Update a log sink. 
 * 
 * @param string $projectId 
 * @param string $sinkName 
 * @param string $filterString 
 */ 
 function update_sink($projectId, $sinkName, $filterString) 
 { 
 $logging = new LoggingClient(['projectId' => $projectId]); 
 $sink = $logging->sink($sinkName); 
 $sink->update(['filter' => $filterString]); 
 printf("Updated a sink '%s'." . PHP_EOL, $sinkName); 
 } 
 

  def 
  
 update_sink 
 ( 
 sink_name 
 , 
 filter_ 
 ): 
  
 """Changes a sink's filter. 
 The filter determines which logs this sink matches and will be exported 
 to the destination. For example a filter of 'severity>=INFO' will send 
 all logs that have a severity of INFO or greater to the destination. 
 See https://cloud.google.com/logging/docs/view/advanced_filters for more 
 filter information. 
 """ 
 logging_client 
 = 
 logging 
 . 
 Client 
 () 
 sink 
 = 
 logging_client 
 . 
 sink 
 ( 
 sink_name 
 ) 
 sink 
 . 
 reload 
 () 
 sink 
 . 
 filter_ 
 = 
 filter_ 
 print 
 ( 
 "Updated sink 
 {} 
 " 
 . 
 format 
 ( 
 sink 
 . 
 name 
 )) 
 sink 
 . 
 update 
 () 
 

  require 
  
 "google/cloud/logging" 
 logging 
  
 = 
  
 Google 
 :: 
 Cloud 
 :: 
  Logging 
 
 . 
 new 
 storage 
  
 = 
  
 Google 
 :: 
 Cloud 
 :: 
  Storage 
 
 . 
 new 
 # bucket_name = "name-of-my-storage-bucket" 
 bucket 
  
 = 
  
 storage 
 . 
 create_bucket 
  
 bucket_name 
 # sink_name = "name-of-my-sink" 
 sink 
  
 = 
  
 logging 
 . 
 sink 
  
 sink_name 
 sink 
 . 
 destination 
  
 = 
  
 "storage.googleapis.com/ 
 #{ 
 bucket 
 . 
 id 
 } 
 " 
 sink 
 . 
 save 
 puts 
  
 "Updated sink destination for 
 #{ 
 sink 
 . 
 name 
 } 
 to 
 #{ 
 sink 
 . 
 destination 
 } 
 "