airflow.providers.amazon.aws.operators.eventbridge

類

EventBridgePutEventsOperator

將事件放置到 Amazon EventBridge 上。

EventBridgePutRuleOperator

建立或更新指定的 EventBridge 規則。

EventBridgeEnableRuleOperator

啟用 EventBridge 規則。

EventBridgeDisableRuleOperator

停用 EventBridge 規則。

模組內容

類 airflow.providers.amazon.aws.operators.eventbridge.EventBridgePutEventsOperator(*, entries, endpoint_id=None, **kwargs)[source]

Bases: airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator[airflow.providers.amazon.aws.hooks.eventbridge.EventBridgeHook]

將事件放置到 Amazon EventBridge 上。

另請參閱

有關如何使用此運算子的更多資訊，請參閱指南：傳送事件到 Amazon EventBridge

引數：
aws_hook_class[source]
template_fields: collections.abc.Sequence[str][source]
entries[source]
endpoint_id = None[source]
execute(context)[source]

建立運算子時派生。

Context 是渲染 Jinja 模板時使用的相同字典。

有關更多 context，請參閱 get_template_context。

類 airflow.providers.amazon.aws.operators.eventbridge.EventBridgePutRuleOperator(*, name, description=None, event_bus_name=None, event_pattern=None, role_arn=None, schedule_expression=None, state=None, tags=None, **kwargs)[source]

Bases: airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator[airflow.providers.amazon.aws.hooks.eventbridge.EventBridgeHook]

建立或更新指定的 EventBridge 規則。

另請參閱

有關如何使用此運算子的更多資訊，請參閱指南：在 Amazon EventBridge 上建立或更新規則

引數：

  • name (str) – 要建立或更新的規則名稱（必填）

  • description (str | None) – 規則描述

  • event_bus_name (str | None) – 要與此規則關聯的事件匯流排的名稱或 ARN

  • event_pattern (str | None) – 要與此規則匹配的事件模式

  • role_arn (str | None) – 與規則關聯的 IAM 角色的 Amazon Resource Name

  • schedule_expression (str | None) – 排程表示式（例如，cron 或 rate 表示式）

  • state (str | None) – 指示規則是設定為“ENABLED”還是“DISABLED”

  • tags (list | None) – 要與規則關聯的鍵值對列表

  • aws_conn_id – 用於 AWS 憑證的 Airflow 連線。如果為 None 或為空，則使用預設的 boto3 行為。如果以分散式方式執行 Airflow 且 aws_conn_id 為 None 或為空，則將使用預設的 boto3 配置（且必須在每個工作節點上維護）。

  • region_name – AWS region_name。如果未指定，則使用預設的 boto3 行為。

  • verify – 是否驗證 SSL 證書。請參閱：https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html

  • botocore_config – botocore 客戶端的配置字典（鍵-值對）。請參閱：https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.htmlt

aws_hook_class[source]
template_fields: collections.abc.Sequence[str][source]
name[source]
description = None[source]
event_bus_name = None[source]
event_pattern = None[source]
role_arn = None[source]
schedule_expression = None[source]
state = None[source]
tags = None[source]
execute(context)[source]

建立運算子時派生。

Context 是渲染 Jinja 模板時使用的相同字典。

有關更多 context，請參閱 get_template_context。

類 airflow.providers.amazon.aws.operators.eventbridge.EventBridgeEnableRuleOperator(*, name, event_bus_name=None, **kwargs)[source]

Bases: airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator[airflow.providers.amazon.aws.hooks.eventbridge.EventBridgeHook]

啟用 EventBridge 規則。

另請參閱

有關如何使用此運算子的更多資訊，請參閱指南：在 Amazon EventBridge 上啟用規則

引數：
aws_hook_class[source]
template_fields: collections.abc.Sequence[str][source]
name[source]
event_bus_name = None[source]
execute(context)[source]

建立運算子時派生。

Context 是渲染 Jinja 模板時使用的相同字典。

有關更多 context，請參閱 get_template_context。

類 airflow.providers.amazon.aws.operators.eventbridge.EventBridgeDisableRuleOperator(*, name, event_bus_name=None, **kwargs)[source]

Bases: airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator[airflow.providers.amazon.aws.hooks.eventbridge.EventBridgeHook]

停用 EventBridge 規則。

另請參閱

有關如何使用此運算子的更多資訊，請參閱指南：在 Amazon EventBridge 上停用規則

引數：
aws_hook_class[source]
template_fields: collections.abc.Sequence[str][source]
name[source]
event_bus_name = None[source]
execute(context)[source]

建立運算子時派生。

Context 是渲染 Jinja 模板時使用的相同字典。

有關更多 context，請參閱 get_template_context。

此條目有用嗎？