airflow.providers.amazon.aws.operators.eventbridge

模块内容

类

EventBridgePutEventsOperator

将事件发送到 Amazon EventBridge。

EventBridgePutRuleOperator

创建或更新指定的 EventBridge 规则。

EventBridgeEnableRuleOperator

启用 EventBridge 规则。

EventBridgeDisableRuleOperator

禁用 EventBridge 规则。
class airflow.providers.amazon.aws.operators.eventbridge.EventBridgePutEventsOperator(*, entries, endpoint_id=None, **kwargs)[源代码]

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

将事件发送到 Amazon EventBridge。

另请参阅

有关如何使用此操作符的更多信息，请查看指南： 将事件发送到 Amazon EventBridge

参数
aws_hook_class[源代码]
template_fields: collections.abc.Sequence[str][源代码]
execute(context)[源代码]

在创建操作符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

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

基类: 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 资源名称

  • 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[源代码]
template_fields: collections.abc.Sequence[str][源代码]
execute(context)[源代码]

在创建操作符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

class airflow.providers.amazon.aws.operators.eventbridge.EventBridgeEnableRuleOperator(*, name, event_bus_name=None, **kwargs)[源代码]

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

启用 EventBridge 规则。

另请参阅

有关如何使用此操作符的更多信息，请查看指南： 在 Amazon EventBridge 上启用规则

参数
aws_hook_class[源代码]
template_fields: collections.abc.Sequence[str][源代码]
execute(context)[源代码]

在创建操作符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

class airflow.providers.amazon.aws.operators.eventbridge.EventBridgeDisableRuleOperator(*, name, event_bus_name=None, **kwargs)[源代码]

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

禁用 EventBridge 规则。

另请参阅

有关如何使用此操作符的更多信息，请查看指南：禁用 Amazon EventBridge 上的规则

参数
aws_hook_class[源代码]
template_fields: collections.abc.Sequence[str][源代码]
execute(context)[源代码]

在创建操作符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

此条目是否有帮助？