airflow.providers.redis.operators.redis_publish

模块内容

类

RedisPublishOperator

将消息发布到 Redis。
class airflow.providers.redis.operators.redis_publish.RedisPublishOperator(*, channel, message, redis_conn_id='redis_default', **kwargs)[源代码]

基类：airflow.models.BaseOperator

将消息发布到 Redis。

参数

  • channel (str) – 要将消息发布到的 redis 通道（模板化）

  • message (str) – 要发布的消息（模板化）

  • redis_conn_id (str) – 要使用的 redis 连接

template_fields: collections.abc.Sequence[str] = ('channel', 'message')[源代码]
execute(context)[源代码]

将消息发布到 Redis 通道。

参数

context (airflow.utils.context.Context) – 上下文对象

此条目是否有帮助？