1

我在 RabbitMQ 中有一个 JSON 格式的队列，我想获取一些数据来修复 StreamSets 中的某些条件（使用流选择器），然后将某个值保存在新数据库（JDBC Producer）中。如何在条件后写入特定值并发送到数据库？

StreamSets 管道

4

2 回答 2

1

从您的管道图中，您似乎正在尝试设置数据库所需的字段值。您应该能够在 JDBC Producer 本身中执行此操作 - 将字段配置为列映射。

于 2017-01-26T19:36:12.080 回答
0

实际上，您可以为它使用名为Expression evaluator的默认流集组件。您可以使用它添加或移动任何字段。

链接到文档： 流集表达式评估器

于 2018-10-20T16:08:02.913 回答