【问题标题】:Streamsets stream selectorStreamsets 流选择器
【发布时间】:2017-01-26 12:03:00
【问题描述】:

我在 RabbitMQ 中有一个 JSON 格式的队列,我想获取一些数据来修复 StreamSets 中的某些条件(使用流选择器),然后将某个值保存在新数据库(JDBC Producer)中。条件后面的具体值如何写到de库?

【问题讨论】:

  • 您应该先尝试自己并在此处提出具体问题。请查看How to Ask页面。
  • 您可以在 StreamSets Google Group 或 Slack 频道上获得特定帮助 - 来自 StreamSets 社区页面streamsets.com/community的链接

标签: conditional-statements streamsets


【解决方案1】:

从您的流水线图中,您似乎正在尝试设置数据库所需的字段值。您应该能够在 JDBC Producer 本身中执行此操作 - 配置 Field to Column Mapping

【讨论】:

    【解决方案2】:

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

    文档链接: streamsets expression evaluator

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2017-03-29
      • 1970-01-01
      • 2018-04-06
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多