airflow.providers.redis.hooks.redis

RedisHook module

Module Contents

Classes

RedisHook

Wrapper for connection to interact with Redis in-memory data structure store

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

Bases: airflow.hooks.base.BaseHook

Wrapper for connection to interact with Redis in-memory data structure store

You can set your db in the extra field of your connection as {"db": 3}. Also you can set ssl parameters as: {"ssl": true, "ssl_cert_reqs": "require", "ssl_cert_file": "/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]
get_conn(self)[source]

Returns a Redis connection.

Was this entry helpful?