airflow.providers.google.cloud.triggers.cloud_composer¶

类¶

`CloudComposerExecutionTrigger`	此触发器处理与 Google Cloud Composer 的异步通信。
`CloudComposerAirflowCLICommandTrigger`	此触发器等待 Airflow CLI 命令结果。
`CloudComposerDAGRunTrigger`	此触发器等待 DAG 运行完成。

模块内容¶

类 airflow.providers.google.cloud.triggers.cloud_composer.CloudComposerExecutionTrigger(project_id, region, operation_name, gcp_conn_id='google_cloud_default', impersonation_chain=None, pooling_period_seconds=30)[source]¶

基类: airflow.triggers.base.BaseTrigger

此触发器处理与 Google Cloud Composer 的异步通信。

project_id[source]¶

region[source]¶

operation_name[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

pooling_period_seconds = 30[source]¶

gcp_hook[source]¶

serialize()[source]¶

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

返回:: 元组 (类路径，重新实例化所需的关键字参数)。
返回类型:: tuple[str, dict[str, Any]]

异步 run()[source]¶

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

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

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

无论哪种情况，触发器类都应假定它们将被持久化，并在不再需要时依赖于 cleanup() 被调用。

类 airflow.providers.google.cloud.triggers.cloud_composer.CloudComposerAirflowCLICommandTrigger(project_id, region, environment_id, execution_cmd_info, gcp_conn_id='google_cloud_default', impersonation_chain=None, poll_interval=10)[source]¶

基类: airflow.triggers.base.BaseTrigger

此触发器等待 Airflow CLI 命令结果。

project_id[source]¶

region[source]¶

environment_id[source]¶

execution_cmd_info[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

poll_interval = 10[source]¶

gcp_hook[source]¶

serialize()[source]¶

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

返回:: 元组 (类路径，重新实例化所需的关键字参数)。
返回类型:: tuple[str, dict[str, Any]]

异步 run()[source]¶

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

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

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

无论哪种情况，触发器类都应假定它们将被持久化，并在不再需要时依赖于 cleanup() 被调用。

类 airflow.providers.google.cloud.triggers.cloud_composer.CloudComposerDAGRunTrigger(project_id, region, environment_id, composer_dag_id, start_date, end_date, allowed_states, gcp_conn_id='google_cloud_default', impersonation_chain=None, poll_interval=10, composer_airflow_version=2)[source]¶

基类: airflow.triggers.base.BaseTrigger

此触发器等待 DAG 运行完成。

project_id[source]¶

region[source]¶

environment_id[source]¶

composer_dag_id[source]¶

start_date[source]¶

end_date[source]¶

allowed_states[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

poll_interval = 10[source]¶

composer_airflow_version = 2[source]¶

gcp_hook[source]¶

serialize()[source]¶

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

返回:: 元组 (类路径，重新实例化所需的关键字参数)。
返回类型:: tuple[str, dict[str, Any]]

异步 run()[source]¶

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

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

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

无论哪种情况，触发器类都应假定它们将被持久化，并在不再需要时依赖于 cleanup() 被调用。

此条目有帮助吗？