Flume将输出格式从. csv更改为. json

Question

我使用的是flume的纯节点(测试)模式；我的水槽以如下方式启动:

水槽节点-1-c$FQDN'：amqp（“exchangeName=[exchange name]”，“bindings=[binding name]””，“host=127.0.0.1”，“port=5672”，“userName=[user]”，”password=[pass]“，”exchangeType=direct“，”durableExchange=false“，”queueName=[queue name]“，“durableQueue=true”，“exclusiveQueue=false”，“autoDeleteQueue=1false””，]@[S3处的路径]“，“服务器”）；'-s“$@”

我有兴趣通过。csv文件与水槽。不幸的是，水槽转弯了。csv文件到。json，添加一些字段。

示例：

原始消息：

"a,b,c"

Flume 将消息转换为：

{"body":"\""a,b,c\"","timestamp":1345380385605,"pri":"INFO","nanos":275832626718182,"host":[host name],"fields":{"rolltag":"20120819-124542793+0000.275789814494811.00000011"}}

如何配置水槽以按原样传递消息？

Answer 1

您可以解析 json 并提取“body”标签。