airflow.providers.cloudant.hooks.cloudant

Hook for Cloudant

Module Contents

class airflow.providers.cloudant.hooks.cloudant.CloudantHook(cloudant_conn_id: str = default_conn_name)[source]

Bases: airflow.hooks.base.BaseHook

Interact with Cloudant. This class is a thin wrapper around the cloudant python library.

See also

the latest documentation here.

Parameters

cloudant_conn_id (str) -- The connection id to authenticate and get a session object from cloudant.

conn_name_attr = cloudant_conn_id[source]
default_conn_name = cloudant_default[source]
conn_type = cloudant[source]
hook_name = Cloudant[source]
static get_ui_field_behaviour()[source]

Returns custom field behaviour

get_conn(self)[source]

Opens a connection to the cloudant service and closes it automatically if used as context manager.

Note

In the connection form: - 'host' equals the 'Account' (optional) - 'login' equals the 'Username (or API Key)' (required) - 'password' equals the 'Password' (required)

Returns

an authorized cloudant session context manager object.

Return type

cloudant

_validate_connection(self, conn: cloudant)[source]

Was this entry helpful?