airflow.providers.redis.hooks.redis

RedisHook module.

Module Contents

Classes

RedisHook

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

Attributes

DEFAULT_SSL_CERT_REQS

ALLOWED_SSL_CERT_REQS

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]

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()[source]

Return a Redis connection.

classmethod get_ui_field_behaviour()[source]

Return custom UI field behaviour for Redis connection.

classmethod get_connection_form_widgets()[source]

Return connection widgets to add to Redis connection form.

Was this entry helpful?