python - 有没有办法将发布到 Kafka 主题的 Avro 文件转换为 python 中的平面 SQL 表?
问题描述
我有一个 Avro 模式(avsc 文件)和以 Avro 格式在 kafka 主题中发布的数据,我需要将其转换为平面 SQL 表。
解决方案
如果数据是由 Confluent Avro 序列化程序之一生成的,您可以使用他们的 Kafka Connect JDBC Sink 写入您选择的 SQL 数据库(例如 sqlite,如果您确实需要文件)
否则,您将需要为此用例编写自己的 Python 代码
推荐阅读
- python - 在 MS SQL 中存储 json 文件
- javascript - 验证数据库 ASP .NET Core 2.2 中是否已存在输入
- reactjs - React Native 模态定位
- nuxt.js - Nuxt 链接到外部 url 在 URL 前添加斜杠
- wordpress - 超出 MySQL 数据库大小限制
- typescript - 如何设置通用约束以确保两种类型之间的公共键也具有相同的值类型?
- html - 位置绝对与文档流混淆
- c - 使用指针(不是 goto)跳转到 C 中的代码行?
- php - Google API 时间戳协议
- mysql - SQL 将发布日期和时间缩短 8 小时