airflow.providers.google.cloud.hooks.cloud_logging¶

Classes¶

CloudLoggingHook

Hook for Google Cloud Logging Log Sinks API.

Module Contents¶

class airflow.providers.google.cloud.hooks.cloud_logging.CloudLoggingHook(gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.common.hooks.base_google.GoogleBaseHook

Hook for Google Cloud Logging Log Sinks API.

Parameters:

gcp_conn_id (str) – The connection ID to use when fetching connection info.
impersonation_chain (str | collections.abc.Sequence[str] | None) – Optional service account to impersonate.

get_conn()[source]¶

Return the Google Cloud Logging Config client.

get_parent(project_id)[source]¶

create_sink(sink, unique_writer_identity=True, project_id=PROVIDE_PROJECT_ID)[source]¶

get_sink(sink_name, project_id=PROVIDE_PROJECT_ID)[source]¶

list_sinks(page_size=None, project_id=PROVIDE_PROJECT_ID)[source]¶

delete_sink(sink_name, project_id=PROVIDE_PROJECT_ID)[source]¶

update_sink(sink_name, sink, unique_writer_identity, update_mask, project_id=PROVIDE_PROJECT_ID)[source]¶