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) – 上下文对象