`airflow.providers.elasticsearch.hooks.elasticsearch`¶

模块内容¶

class airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchHook(schema: str = 'http', connection: Optional[AirflowConnection] = None, *args, **kwargs)[源代码]¶

基类: airflow.hooks.dbapi.DbApiHook

通过 elasticsearch-dbapi 与 Elasticsearch 交互。

conn_name_attr = elasticsearch_conn_id[源代码]¶

default_conn_name = elasticsearch_default[源代码]¶

conn_type = elasticsearch[源代码]¶

hook_name = Elasticsearch[源代码]¶

get_conn(self)[源代码]¶: 返回一个 elasticsearch 连接对象

get_uri(self)[源代码]¶

此条目有帮助吗？