airflow.providers.redis.hooks.redis¶

RedisHook 模块。

属性¶

`DEFAULT_SSL_CERT_REQS`
`ALLOWED_SSL_CERT_REQS`

类¶

用于连接并与 Redis 内存数据结构存储交互的包装器。

模块内容¶

airflow.providers.redis.hooks.redis.DEFAULT_SSL_CERT_REQS = 'required'[source]¶

airflow.providers.redis.hooks.redis.ALLOWED_SSL_CERT_REQS[source]¶

class airflow.providers.redis.hooks.redis.RedisHook(redis_conn_id=default_conn_name)[source]¶

基础类：airflow.hooks.base.BaseHook

用于连接并与 Redis 内存数据结构存储交互的包装器。

您可以在连接的 extra 字段中设置数据库，例如 {"db": 3}。您还可以设置 ssl 参数，例如： {"ssl": true, "ssl_cert_reqs": "require", "ssl_certfile": "/path/to/cert.pem", etc}。

conn_name_attr = 'redis_conn_id'[source]¶

default_conn_name = 'redis_default'[source]¶

conn_type = 'redis'[source]¶

hook_name = 'Redis'[source]¶

redis_conn_id = 'redis_default'[source]¶

redis = None[source]¶

host = None[source]¶

port = None[source]¶

username = None[source]¶

password = None[source]¶

db = None[source]¶

get_conn()[source]¶: 返回一个 Redis 连接。

classmethod get_ui_field_behaviour()[source]¶

返回 Redis 连接的自定义 UI 字段行为。

classmethod get_connection_form_widgets()[source]¶

返回要添加到 Redis 连接表单的连接小部件。

本条目有帮助吗？