我想在Airflow中使用Elasticsearch聚合功能。我的Airflow版本是2.6.2,我使用的是Elasticsearch版本7.10.2。
但是,当我按如下方式配置连接时,测试成功,但我遇到连接错误。
连接详情:
主机:弹性(容器名称)
架构:http
端口:9600(自定义)
我注意到聚合是使用**/_search
**URL执行的,但使用Airflow的内置连接似乎是不可能的。
我已经使用提供的连接详细信息在Airflow中配置了Elasticsearch连接。
我希望能够在我的Airflow任务中使用Elasticsearch聚合,而不会出现任何连接问题。
1条答案
按热度按时间cczfrluj1#
你可以尝试使用elasticsearch provider package。这与built-in elasticsearch connection objects以及built-in hooks一起提供,用于调用elasticsearch。