为 InfoSphere Warehouse 提供实时数据的高效解决方案

核心提示： 图 6. MQ Connector 设置查看原图（大图）接着，我们需要使用 DataStage Transform Stage 对 MQ 的消息进行处理，为 InfoSphere Warehouse 提供实时数据的高效解决方案(10)，并行实现一些逻辑转换，在 Transform 中，图 7.

图 6. MQ Connector 设置

查看原图（大图）

接着，我们需要使用 DataStage Transform Stage 对 MQ 的消息进行处理。并行实现一些逻辑转换。在 Transform 中，我们先要知道某条消息包括了一个什么的操作，以便把相同的操作应用到数据仓库。如图所示，我们定义了一个约束，针对不同的操作 “DLET”,“REPL”和“ISRT”定义了不同的数据输出。其中 , “operator”是一个变量，我们使用 DataStage 内部函数 Field() 读出每条消息的第五个字段，并且使用 Trim() 函数去掉双引号后赋给该变量。

图 7. 添加 Transform Stage 约束

查看原图（大图）

然后，我们从消息中读取包含的数据信息，并且这些数据信息映射到对应的的输出中。

图 8. 映射 Transform Stage 的输入与输出