文章/答案/技术大牛

发布

社区首页 >问答首页 >如何使用InfluxDB将消息接收到PyFlink？

问如何使用InfluxDB将消息接收到PyFlink？
EN

Stack Overflow用户

提问于 2022-06-13 13:58:13

回答 1查看 181关注 0票数 1

我正在尝试运行PyFlink漫游，但我不想将数据转移到Elasticsearch，我想使用InfluxDB。

注意:演练中的代码(上面的链接)正在按预期工作。

为了使这个工作，我们需要把InfluxDB连接器内的码头容器。其他Flink连接器被放置在容器中，在Dockerfile中使用以下命令

# Download connector libraries
RUN wget -P /opt/flink/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-json/${FLINK_VERSION}/flink-json-${FLINK_VERSION}.jar; \
    wget -P /opt/flink/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-kafka_2.12/${FLINK_VERSION}/flink-sql-connector-kafka_2.12-${FLINK_VERSION}.jar; \
    wget -P /opt/flink/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7_2.12/${FLINK_VERSION}/flink-sql-connector-elasticsearch7_2.12-${FLINK_VERSION}.jar;

我需要帮助以便：

将InfluxDB连接器放入容器中
修改下面的CREATE TABLE语句，以便为InfluxDB工作

        CREATE TABLE es_sink (
            id VARCHAR,
            value DOUBLE
        ) with (
                'connector' = 'elasticsearch-7',
                'hosts' = 'http://elasticsearch:9200',
                'index' = 'platform_measurements_1',
                'format' = 'json'
            )

pyflink

apache-flink

flink-streaming

influxdb

flink-sql

回答 1

Stack Overflow用户

回答已采纳

发布于 2022-06-14 15:16:02

来自文档

表和SQL目前(14/06/2022)不支持InfluxDB --不存在sql/table连接器。

以下是您可以使用的已知连接器：

来自Maven Apache Flink
来自阿帕奇巴希尔

您可以：

票数 1

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/72604134

复制

相似问题

问如何使用InfluxDB将消息接收到PyFlink？
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何使用InfluxDB将消息接收到PyFlink？EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何使用InfluxDB将消息接收到PyFlink？
EN