如何在Pyflink中连接Flink和Elasticsearch?

2ekbmq32  于 2022-12-16  发布在  Apache
关注(0)|答案(1)|浏览(143)

我的目标是创建一个与Kafka〉Flink〉ElasticSearch〉Kibana相关的真实的处理项目。
我可以在Flink中使用来自Kafka的信息,但不能连接Flink和ElasticSearch。我如何将Flink中使用的Kafka信息发送到ElasticSearch?
我的python 3.8环境包括:高速缓存- Flink =1.15.0

ars1skjm

ars1skjm1#

您可以使用Table API创建Elasticsearch Sink表:
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/table/python_table_api_connectors/#how-to-use-connectors
https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/elasticsearch/#how-to-create-an-elasticsearch-table
如果您需要将DataStream转换为Table API,您可以在这里找到一些帮助:https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/data_stream_api/

相关问题