docker - Nifi将数据插入Docker上的Druid

Question

我在不同的服务器上安装了2个docker-container

docker 德鲁伊

docker-NiFi

当我使用NiFi将数据插入德鲁伊时，出现以下错误:

你有什么想法？德鲁伊该如何配置？
非常感谢 :)

Answer 1

在阅读器/书写器 Controller 服务中使用时

模式访问策略作为使用'SchemaName'属性然后

确保您具有与流文件相关联的 schema.name 属性。

要添加属性，请使用更新属性处理器

添加名为
schema.name ，值为 schema_name

示例:

如果您正在使用AvroSchemaRegistry访问架构，则架构的名称将为您的schema.name属性值。

有关更多详细信息，请引用this链接，并在流程中查看 UpdateAttribute 处理器的配置。

更新:

根据您的示例数据，而不是使用JsonPathReader，请使用JsonTreeReader和JsonSetWriter Controller 服务。

您缺少AvroSchemaRegistry Controller 服务中的架构属性。

在AvroSchemaRegistry中，通过单击右上角的+号添加属性

演示

{
    "type": "record",
    "name": "balances",
    "namespace": "nifi",
    "fields": [{
        "name": "submit_date",
        "type": ["null",
        "string"]
    },
    {
        "name": "request_type",
        "type": ["null",
        "string"]
    },
    {
        "name": "origin",
        "type": ["null",
        "string"]
    },{
        "name": "description",
        "type": ["null",
        "string"]
    }]
}