如何将 Avro 转换为 SQL 批量更新?

Question

我正在尝试将输入 Avro(Avro 记录数组(转换为一批更新插入状态。有没有可以做到这一点的处理器？

[读取外部数据库(RDBMS(]->[Avro to upsert batch]->[本地数据库]

我发现记录可以用sql格式化。N.args.type & name 在 PutSQL 之前。通过这种方法，是否有处理器或技巧可以使它变得干净？

[读取外部数据库(RDBMS(]->[拆分为1]->[将Avro转换为 .sql。N.args.type and name format]->[SetAttribute： sql.statement=SQL]->[Local DB]

在第两种情况下，我被困在[将Avro转换为sql。N.args.type and name format]，我试图抵制使用ExecuteScript的冲动......最简单的前进方向是什么？

Answer 1

如果您需要生成 SQL(例如，进行更新插入与插入(，您可以使用 ConvertJSONToSQL(假设您的内容是 JSON(，它为您完成所有 sql.args.N 工作。如果您使用 ExecuteSQLRecord 或 QueryDatabaseTableRecord，则可以将源数据库信息作为 JSON(通过使用 JsonRecordSetWriter(与仅输出 Avro 的非基于记录的版本相比。否则，在 ConvertJSONToSQL 之前，您需要一个 ConvertAvroToJSON。