airflow.providers.elasticsearch.hooks.elasticsearch¶

类¶

`ElasticsearchSQLCursor`	一个类似 PEP 249 的 Elasticsearch SQL API Cursor 类。
`ESConnection`	elasticsearch.Elasticsearch 的包装类。
`ElasticsearchSQLHook`	通过 elasticsearch-dbapi 与 Elasticsearch 交互。
`ElasticsearchPythonHook`	与 Elasticsearch 交互。此 hook 使用官方的 Elasticsearch Python 客户端。

函数¶

connect([host, port, user, password, scheme])

模块内容¶

airflow.providers.elasticsearch.hooks.elasticsearch.connect(host='localhost', port=9200, user=None, password=None, scheme='http', **kwargs)[source]¶

class airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor(es, **kwargs)[source]¶

一个类似 PEP 249 的 Elasticsearch SQL API Cursor 类。

es[source]¶

body[source]¶

property response: elastic_transport.ObjectApiResponse[source]¶

property cursor[source]¶

property rows[source]¶

property rowcount: int[source]¶

property description: list[tuple][source]¶

execute(statement, params=None)[source]¶

fetchone()[source]¶

abstract fetchmany(size=None)[source]¶

fetchall()[source]¶

close()[source]¶

class airflow.providers.elasticsearch.hooks.elasticsearch.ESConnection(host='localhost', port=9200, user=None, password=None, scheme='http', **kwargs)[source]¶

elasticsearch.Elasticsearch 的包装类。

host = 'localhost'[source]¶

port = 9200[source]¶

user = None[source]¶

password = None[source]¶

scheme = 'http'[source]¶

kwargs[source]¶

url[source]¶

cursor()[source]¶

close()[source]¶

commit()[source]¶

execute_sql(query, params=None)[source]¶

class airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLHook(schema='http', connection=None, *args, **kwargs)[source]¶

基类: airflow.providers.common.sql.hooks.sql.DbApiHook

通过 elasticsearch-dbapi 与 Elasticsearch 交互。

此 hook 使用 Elasticsearch conn_id。

参数:: elasticsearch_conn_id – 用于 Elasticsearch 凭据的 ElasticSearch 连接 ID。

conn_name_attr = 'elasticsearch_conn_id'[source]¶

default_conn_name = 'elasticsearch_default'[source]¶

connector[source]¶

conn_type = 'elasticsearch'[source]¶

hook_name = 'Elasticsearch'[source]¶

schema = 'http'[source]¶

get_conn()[source]¶

返回一个 elasticsearch 连接对象。

get_uri()[source]¶

从连接中提取 URI。

返回值:: 提取的 uri。
返回类型:: str

class airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchPythonHook(hosts, es_conn_args=None)[source]¶

基类: airflow.hooks.base.BaseHook

与 Elasticsearch 交互。此 hook 使用官方的 Elasticsearch Python 客户端。

参数:

hosts (list[Any]) – list: 单个或多个 Elasticsearch 实例的列表。示例：[”http://localhost:9200”]
es_conn_args (dict | None) – dict: 连接到 Elasticsearch 可能需要输入的额外参数。示例：{“ca_cert”:”/path/to/cert”, “basic_auth”: “(user, pass)”}

hosts[source]¶

es_conn_args[source]¶

property get_conn[source]¶: 返回 Elasticsearch 客户端（已缓存）。

search(query, index='_all')[source]¶

使用 Elasticsearch DSL 返回匹配查询的结果。

参数:

index (str) – str: 你想要查询的索引
query (dict[Any, Any]) – dict: 你想要运行的查询

返回值:

dict: 来自 Elasticsearch 的响应 'hits' 对象

返回类型:

dict