如何解决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
)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。