airflow.providers.redis.operators.redis_publish

RedisPublishOperator

向 Redis 发布消息。

模块内容

class airflow.providers.redis.operators.redis_publish.RedisPublishOperator(*, channel, message, redis_conn_id='redis_default', **kwargs)[source]

基类: airflow.models.BaseOperator

向 Redis 发布消息。

参数:
  • channel (str) – Redis 通道,消息将发布到该通道(模板化)

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

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

template_fields: collections.abc.Sequence[str] = ('channel', 'message')[source]
redis_conn_id = 'redis_default'[source]
channel[source]
message[source]
execute(context)[source]

将消息发布到 Redis 通道。

参数:

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

此条目有帮助吗?