19
19
from google .cloud import logging
20
20
21
21
22
+ # [START logging_list_sinks]
22
23
def list_sinks ():
23
24
"""Lists all sinks."""
24
25
logging_client = logging .Client ()
@@ -30,8 +31,10 @@ def list_sinks():
30
31
31
32
for sink in sinks :
32
33
print ('{}: {} -> {}' .format (sink .name , sink .filter_ , sink .destination ))
34
+ # [END logging_list_sinks]
33
35
34
36
37
+ # [START logging_create_sink]
35
38
def create_sink (sink_name , destination_bucket , filter_ ):
36
39
"""Creates a sink to export logs to the given Cloud Storage bucket.
37
40
@@ -61,8 +64,10 @@ def create_sink(sink_name, destination_bucket, filter_):
61
64
62
65
sink .create ()
63
66
print ('Created sink {}' .format (sink .name ))
67
+ # [END logging_create_sink]
64
68
65
69
70
+ # [START logging_update_sink]
66
71
def update_sink (sink_name , filter_ ):
67
72
"""Changes a sink's filter.
68
73
@@ -80,9 +85,10 @@ def update_sink(sink_name, filter_):
80
85
sink .filter_ = filter_
81
86
print ('Updated sink {}' .format (sink .name ))
82
87
sink .update ()
83
- # [END update ]
88
+ # [END logging_update_sink ]
84
89
85
90
91
+ # [START logging_delete_sink]
86
92
def delete_sink (sink_name ):
87
93
"""Deletes a sink."""
88
94
logging_client = logging .Client ()
@@ -91,6 +97,7 @@ def delete_sink(sink_name):
91
97
sink .delete ()
92
98
93
99
print ('Deleted sink {}' .format (sink .name ))
100
+ # [END logging_delete_sink]
94
101
95
102
96
103
if __name__ == '__main__' :
0 commit comments