pentaho - transform a data row from mysql database to queue using jms producer in pentaho

Question

I want to read data from database and send each row of data to a queue. but in jms producer editor, I can choose just one column of each row as message field.

for example: I have a table with (id,name,family,address,postcode) fields. I need to send each row of data to queue. But in jms producer editor, there is message field drop-down list which makes me to choose just one of above fields as message field(e.g. id or name or family ...) How can I send whole row data to queue as one message.

Answer 1

我不熟悉 JMS，但这种情况需要将数据包装成可以作为消息发布的格式。

我将使用 JSON 输出步骤，将每一行转换为 JSON 对象（进入消息字段）。将其配置为输出值，而不是文件，并将块中的 Nr 行设置为 1。在字段选项卡上，包括要迁移的所有字段。

XML 输出也是一种选择。无论哪种方式，您可能还需要转义已编译消息上的任何 HTML/XML 代码和/或将其包装在 CDATA 标记中，具体取决于行的内容。

在接收端，可以将 JSON 解码回字段。您将丢失需要单独验证的确切数据类型和长度元数据。