我正在尝试运行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'
            )