Загрузка данных CSV в базу данных MySQL в NiFi

Question

Я пытаюсь вставить данные моего CSV-файла в MySQL Db.В моем CSV-файле есть поле с именем ' MeasurementTime ' и значением 2018-06-27 11: 14.50 .Мой поток принимает это поле как строку, и поэтому PutSQL выдает ошибку.Я использую тот же шаблон, что и в этом шаблоне , но не использую процессор InferAvro , поскольку у меня уже есть предопределенная схема.Это веб-сайт Ссылка на веб-сайт

Как я могу передать поле Datetime в мою базу данных MySQL как правильный тип данных, а не как строку.Какие настройки я должен изменить?

Спасибо

Answer 1

С PutDatabaseRecord вы можете избежать всей этой цепочки трансформаций и сверхинженерии.Поток будет выглядеть так:

GetFile -> PutDatabaseRecord

Вам необходимо настроить PutDatabaseRecord со свойством RecordReader, настроенным на CSVReader, и настроить CSVReader и установить его Schema Registry на AvroSchemaRegistry и предоставитьдействительная схема.Вы можете найти шаблон для образца потока здесь .