airflow.providers.google.cloud.triggers.cloud_sql¶

此模块包含 Google Cloud SQL 触发器。

类¶

CloudSQLExportTrigger

一种触发器，定期轮询 Cloud SQL API 以验证作业状态。

模块内容¶

class airflow.providers.google.cloud.triggers.cloud_sql.CloudSQLExportTrigger(operation_name, project_id=PROVIDE_PROJECT_ID, gcp_conn_id='google_cloud_default', impersonation_chain=None, poke_interval=20)[source]¶

基类：airflow.triggers.base.BaseTrigger

一种触发器，定期轮询 Cloud SQL API 以验证作业状态。

实现利用异步传输。

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

operation_name[source]¶

project_id = None[source]¶

poke_interval = 20[source]¶

hook[source]¶

serialize()[source]¶

返回重建此触发器所需的信息。

返回：: 一个元组，包含（类路径，重新实例化所需的关键字参数）。

async run()[source]¶

在异步上下文中运行触发器。

当触发器需要触发事件时，应 yield 一个 Event；如果完成，则返回 None。因此，单事件触发器应先 yield 然后立即返回。

如果它 yield，则很可能会很快恢复，但也可能不会（例如，如果工作负载正在转移到另一个触发器进程，或者多事件触发器被用于单事件任务延迟）。

在任何情况下，触发器类都应假定自身会被持久化，然后在不再需要时依赖于 cleanup() 方法的调用。