我正在尝试将elasticsearch_async(存储库(与龙卷风 6.0.3 一起使用。
根据我对代码的理解,如果我使用AsyncElasticSearch
并通过当前的龙卷风ioloop
,它将起作用。有人可以确认或指出一个例子吗?
我的第二个问题是 - 我看到AsyncElasticSearch
内部使用AIOHttpConnection
(代码(作为默认connection_class
.我是否需要创建一个新的connection_class
适配器以传递给使用龙卷风AsyncHttpClient
的connection_class
,或者龙卷风是否会与AIOHttpConnection
无缝协作?
根据我对代码的理解,如果我使用 AsyncElasticSearch 并通过当前的龙卷风 ioloop,它将起作用。有人可以确认或指出一个例子吗?
AsyncElasticSearch 想要一个asyncio
事件循环,而不是 Tornado IOLoop。但是在Tornado 6中,Tornado IOLoop只是asyncio事件循环的包装器,所以如果你忽略所有这些并使用默认值,一切都应该可以正常工作。
我是否需要创建一个新的connection_class适配器以传递给使用龙卷风的AsyncHttpClient的connection_class,或者龙卷风是否会与AIOHttpConnection无缝协作?
不。只需让 AsyncElasticSearch 使用 aiohttp,即使应用程序的其他部分使用 AsyncHTTPClient。它应该一起工作(尽管我实际上还没有尝试过这种组合(。