У меня на разных серверах установлено 2 докер-контейнера
Когда я использовал NiFi для вставки данных в druid, у меня была такая ошибка:
У тебя есть идеи? Как сделать эту конфигурацию для друида?
Большое спасибо :)
Как вы используете в своих службах контроллера Reader / Writer
Стратегия доступа к схеме как Используйте свойство SchemaName, тогда
Убедитесь, что у вас есть атрибут schema.name, связанный с потоковый файл.
Для добавления атрибута используйте процессор Обновить атрибут
добавить новое свойство под названием schema.name и значение как schema_name
Пример:
если вы используете AvroSchemaRegistry для доступа к схеме, тогда имя схемы будет вашим значением атрибута schema.name.
Для более подробной информации обратитесь к ссылке это и посмотрите конфиги процессора UpdateAttribute в потоке.
Обновлять:
В соответствии с вашими образцами данных вместо использования JsonPathReader используйте службы контроллера JsonTreeReader и JsonSetWriter.
В службе контроллера AvroSchemaRegistry отсутствует свойство схемы.
в 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"]
}]
}
@ThuyLe, есть ли какая-то конкретная причина использовать службу контроллера JsonPathReader? .. если не использовать службу Контроллер JsonTreeReader в качестве этой службы контроллера, необходимо указать не нужно добавлять пути JSON ... для получения дополнительной информации о читателе jsonpath nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/…
Спасибо @Shu, я понял, что ошибка теперь новая ошибка при потоковой передаче данных в druid. См. Вопрос об обновлении
Привет, @Shu, Обновить картинки вставить данные в druid -config и вставить данные в druid -config_1, а также ошибка err вставить данные в druid [1]: i.stack.imgur.com/dXRTr.png [2]: i.stack.imgur.com/uzn6f.png [3]: i.stack.imgur.com/IcDTz.png
Привет, Шу, пожалуйста, посмотрите обновленные изображения, теперь, после того, как я выполнил шаги, поскольку в ваших предложениях появилась новая ошибка «Пути JSON» недействительна, потому что НЕ были указаны пути JSON