AsyncElasticsearch 客户端不接受与 AWS Elasticsearch 的连接 - AttributeError: 'AWS4Auth' 对象没有属性 'encode'

问题描述

我在我的项目中使用 AWS Elasticsearch 和 async elasticsearch-py 包来连接集群。

AWS Elasticsearch 版本 7.9

Python 包：elasticsearch[async]==7.12.0

我无法使用 AWS4Auth 库（在官方 AWS ES 客户端 Python 文档中提到）初始化异步 Elasticsearch 客户端

它应该成功连接到客户端。但是，它给了我这个错误：

AttributeError: 'AWS4Auth' object has no attribute 'encode'

分享我的代码片段：

from elasticsearch import AsyncElasticsearch,AIOhttpconnection
from requests_aws4auth import AWS4Auth
import asyncio

host = 'my-test-domain.us-east-1.es.amazonaws.com'
region = 'us-east-1'
service = 'es'

credentials = {
    'access_key': "MY_ACCESS_KEY",'secret_key': "MY_SECRET_KEY"
}

awsauth = AWS4Auth(credentials['access_key'],credentials['secret_key'],region,service)

es = AsyncElasticsearch(
    hosts=[{'host': host,'port': 443}],http_auth=awsauth,use_ssl=True,verify_certs=True,connection_class=AIOhttpconnection
)

async def test():
    print(await es.info())

asyncio.run(test())

解决方法

我认为使用 AWS4Auth，您将绑定到 RequestsHttpConnection。

默认的连接类是基于urllib3的，比较多 比可选的基于请求的类性能和轻量级。 如果您需要任何请求，请仅使用 RequestsHttpConnection 高级功能，如自定义身份验证插件等。

来自https://elasticsearch-py.readthedocs.io/en/master/transports.html

试试：

es = AsyncElasticsearch(
     hosts=[{'host': host,'port': 443}],http_auth=awsauth,use_ssl=True,verify_certs=True,connection_class=RequestsHttpConnection
)

或非异步版本，如果上面的代码不起作用：

es = Elasticsearch(
     hosts=[{'host': host,connection_class=RequestsHttpConnection
)