ConvertAvroToJSON

概述

将流文件属性转化成json，传输到下级流文件内容或属性上。

属性说明

输出选项

确定Avro流如何输出，是整体Json数组还是每个对象一行

• JSON数组
• 对象列表

单记录包装

仅在"输出选项"为JSON数组时生效，控制单条数据或空数据的输出格式。

• 不包装
• 始终数组

Avro模式(schema)

上级流文件的Avro数据缺失schema信息时，需要单独配置指定avro.schema内容。

示例

流程说明

我们从数据库查询出的数据一般使用avro格式描述数据，也就是avro数据。 样例里我们先查询数据库的数据，后续配置ConvertAvroToJSON转换数据。

###样本数据 我们有表"demo", 数据如下：

id|name|city|age
0|张三|北京|18
1|李四|上海|48

###配置说明 1.QueryDatabaseTable配置查询表名，数据库连接池正确配置。

2.设置ConvertAvroToJSON，保持默认设置即可，当前场景中上级直接从数据库查询数据，avro数据schema是完善的。 如果实际场景中上级不是带avro.shema的avro数据，需要配置"Avro模式(schema)"。

###结果 输出流文件的内容：

[{"id": 0, "name": "张三", "city": "北京", "age": 18},{"id": 1, "name": "李四", "city": "上海", "age": 48}]

如果更改设置"输出选项"为 对象列表, 输出结果如下：

{"id": 0, "name": "张三", "city": "北京", "age": 18}
{"id": 1, "name": "李四", "city": "上海", "age": 48}

流程模板

参见附件(请右键另存保存)：模板文件