`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)[原始碼]¶

Bases: 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`¶