将elasticsearch_async与龙卷风一起使用



我正在尝试将elasticsearch_async(存储库(与龙卷风 6.0.3 一起使用。

根据我对代码的理解,如果我使用AsyncElasticSearch并通过当前的龙卷风ioloop,它将起作用。有人可以确认或指出一个例子吗?

我的第二个问题是 - 我看到AsyncElasticSearch内部使用AIOHttpConnection(代码(作为默认connection_class.我是否需要创建一个新的connection_class适配器以传递给使用龙卷风AsyncHttpClientconnection_class,或者龙卷风是否会与AIOHttpConnection无缝协作?

根据我对代码的理解,如果我使用 AsyncElasticSearch 并通过当前的龙卷风 ioloop,它将起作用。有人可以确认或指出一个例子吗?

AsyncElasticSearch 想要一个asyncio事件循环,而不是 Tornado IOLoop。但是在Tornado 6中,Tornado IOLoop只是asyncio事件循环的包装器,所以如果你忽略所有这些并使用默认值,一切都应该可以正常工作。

我是否需要创建一个新的connection_class适配器以传递给使用龙卷风的AsyncHttpClient的connection_class,或者龙卷风是否会与AIOHttpConnection无缝协作?

不。只需让 AsyncElasticSearch 使用 aiohttp,即使应用程序的其他部分使用 AsyncHTTPClient。它应该一起工作(尽管我实际上还没有尝试过这种组合(。

最新更新