| :py:mod:`airflow.providers.elasticsearch.hooks.elasticsearch` |
| ============================================================= |
| |
| .. py:module:: airflow.providers.elasticsearch.hooks.elasticsearch |
| |
| |
| Module Contents |
| --------------- |
| |
| Classes |
| ~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchHook |
| |
| |
| |
| |
| .. py:class:: ElasticsearchHook(schema = 'http', connection = None, *args, **kwargs) |
| |
| Bases: :py:obj:`airflow.hooks.dbapi.DbApiHook` |
| |
| Interact with Elasticsearch through the elasticsearch-dbapi. |
| |
| This hook uses the Elasticsearch conn_id. |
| |
| :param elasticsearch_conn_id: The :ref:`ElasticSearch connection id <howto/connection:elasticsearch>` |
| used for Elasticsearch credentials. |
| |
| .. py:attribute:: conn_name_attr |
| :annotation: = elasticsearch_conn_id |
| |
| |
| |
| .. py:attribute:: default_conn_name |
| :annotation: = elasticsearch_default |
| |
| |
| |
| .. py:attribute:: conn_type |
| :annotation: = elasticsearch |
| |
| |
| |
| .. py:attribute:: hook_name |
| :annotation: = Elasticsearch |
| |
| |
| |
| .. py:method:: get_conn(self) |
| |
| Returns a elasticsearch connection object |
| |
| |
| .. py:method:: get_uri(self) |
| |
| Extract the URI from the connection. |
| |
| :return: the extracted uri. |
| |
| |
| |
