apache / apache/iotdb-extras

[Feature request] Python example for IOTDB sink from apache-flink

未关闭
#97 1 条评论 0 个 reaction 已指派 0 人 在 GitHub 查看
主要语言
Java
星标
33
派生
29
平均合并
1 天 3 小时
30 天内合并 PR
5

描述

### Search before asking

- [x] I searched in the [issues](https://github.com/apache/iotdb/issues) and found nothing similar.

### Motivation

Is there an example to send data to IoTDB using flink with it's official python package that is PyFlink [apache-flink](https://pypi.org/project/apache-flink/). Tried to use the flink-connector jars but could not do it. My flink version is 2.1.0 and IoTdb version is 2.0.4.

### Solution

Integration of python function in [apache-iotdb](https://pypi.org/project/apache-iotdb/) from flink to iotdb.

### Alternatives

_No response_

### Are you willing to submit a PR?

- [ ] I'm willing to submit a PR!

贡献指南

这个仓库没有索引到贡献指南

调研方向

未指定任何仓库文件或测试。结合 PyFlink 和 apache-iotdb package 的官方文档,查看现有的 IoTDB connector 示例,并使用 Flink 2.1.0 和 IoTDB 2.0.4 作为兼容性目标。当有一个文档齐全且可运行的 Python 示例,能够将数据从 Flink 发送到 IoTDB 时,即视为完成。

由索引模型根据 Issue 内容生成。

评估

技术栈
python
领域
data-engineering, databases
Issue 类型
功能
难度
4/5
预计耗时
3-5 天
活跃度
停滞
描述清晰度
基本清楚
新手友好度
35/100

把新 issue 发到你的邮箱

精选适合新手参与的 GitHub issue 摘要。