`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)[源代码]¶

基类：airflow.triggers.base.BaseTrigger

定期从 Cloud SQL API 轮询信息以验证作业状态的触发器。

实现利用异步传输。

serialize()[源代码]¶

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

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

async run()[源代码]¶

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

触发器应在需要触发事件时生成一个事件，并在完成时返回 None。因此，单事件触发器应生成然后立即返回。

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

在任何一种情况下，触发器类都应假设它们将被持久化，然后依赖于不再需要它们时调用的 cleanup()。

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

模块内容¶

类¶

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