我正在尝试运行PyFlink walkthough,但我想使用InfluxDB,而不是将数据下沉到Elasticsearch。
注意:演练中的代码(上面的链接)按预期工作。
为了让它正常工作,我们需要把InfluxDB连接器放在docker容器中。其他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'
)
1条答案
按热度按时间vc9ivgsu1#
从documentation:
表和SQL API目前(14/06/2022)不支持InfluxDB -SQL/表连接器不存在。
以下是您可以使用的已知连接器:
您可以:
或