使用 python 在 Elasticsearch 中进行 API 密钥身份验证

Question

我希望找到弹性搜索 python 框架问题的答案。也许我完全失明或做错了什么，但我现在很困惑，找不到合适的答案。

我目前正在尝试使用elasticsearch python framework 与我的弹性搜索 API 建立连接，我的代码如下所示：

from elasticsearch import Elasticsearch

def create_es_connection(host: str, port: int, api_key_id: str, api_key: str, user: str, pw: str) -> Elasticsearch:
    return Elasticsearch([f"https://{user}:{pw}@{host}:{port}"])

这工作正常。然后我为我的 testuser 创建了一个 API 密钥，我也将它提供给了上面的函数。我现在正在尝试做类似这样的事情：Elasticsearch([f"https://{api_key_id}:{api_key}@{host}:{port}"]) 所以，我想完全省略用户和密码，因为关于这个 sn-p 背后的更大项目，我在保存时感觉不太好我项目中的用户/密码凭据（甚至可能将其推送到我们的 git 服务器）。迟早，这些凭据必须在某个地方输入，我在想只保存 API 密钥并使用它进行身份验证可能更安全。不幸的是，这并没有按我的计划进行，我找不到任何关于如何仅使用 API 密钥进行身份验证的信息。

我做错了什么？事实上，我对此发现的太少了，以至于我在这里质疑我的基本理解。感谢您的回复！

Answer 1

我的工作配置是：

es = Elasticsearch(['localhost:9200'], api_key=('DuSkVm8BZ5TMcIF99zOC','2rs8yN26QSC_uPr31R1KJg'))

Answer 2

Elasticsearch 的文档展示了如何生成和使用（在页面底部）API 密钥：https://www.elastic.co/guide/en/elasticsearch/reference/current/security-api-create-api-key.html

curl -H "Authorization: ApiKey ..." http://localhost:9200/_cluster/health

-H 表示“标题”，因此要在 Python 中执行相同操作，您需要设置此标题。翻阅 elasticsearch 模块源代码告诉我，您可能只能执行以下操作：

Elasticsearch([f'http://{host}:{port}'], api_key=api_key)

原因是Elasticsearch.__init__方法的**kwargs被传递给Transport.__init__，其中的**kwargs被传递给Connection.__init__, which takes an api_key arg，然后在 _get_api_key_header_val 构造相应的标头。

以下代码显示 api 密钥头被添加到请求的 HTTP 头中：

import elasticsearch, logging, http.client
http.client.HTTPConnection.debuglevel = 5
logging.basicConfig(level=logging.DEBUG)
c = elasticsearch.Elasticsearch(['localhost'], api_key='TestApiKey')
print(c.cluster.health(wait_for_status='green'))

这绝对是应该添加到 Elasticsearch 文档中的内容。