ElasticsearchPythonHook¶

Elasticsearch Hook 使用原生 Python 客戶端與 Elasticsearch 通訊

參數¶

hosts

單個或多個 Elasticsearch 實例的列表。範例：["https://127.0.0.1:9200"]。

es_conn_args

您可能需要輸入以連接到 Elasticsearch 的其他參數。範例：{"ca_cert":"/path/to/cert", "basic_auth": "(user, pass)"}

有關所有可能的配置，請查閱 Elasticsearch 文件。參考文獻：https://www.elastic.co/guide/en/elasticsearch/client/python-api/current/connecting.html

使用範例¶

tests/system/elasticsearch/example_elasticsearch_query.py[原始碼]

def use_elasticsearch_hook():
    """
    Use ElasticSearchPythonHook to print results from a local Elasticsearch
    """
    es_hosts = ["https://127.0.0.1:9200"]
    es_hook = ElasticsearchPythonHook(hosts=es_hosts)
    query = {"query": {"match_all": {}}}
    result = es_hook.search(query=query)
    print(result)
    return True