简单的 Stream 例子

作为一个简单处理步骤的示例，我们可以使用以下 Stream definition 将 http 中给到的数据通过 transform 转换为大写的形式正在传递给 log： http | transform --expression=payload.toUpperCase() | log

要创建发布此 Stream，请在shell中输入以下命令

dataflow:> stream create --definition "http --server.port=9000 | transform --expression=payload.toUpperCase() | log" --name mystream --deploy

以下示例使用shell命令发布了一些数据：

dataflow:> http post --target http://localhost:9000 --data "hello"

上面的例子的结果，在log中以返回大写“HELLO”，如下所示:

2016-06-01 09:54:37.749 INFO 80083 --- [ kafka-binder-] log.sink : HELLO