PutMongoRecord
Описание
Этот процессор является процессором, учитывающим записи, для вставки/обновления данных в MongoDB. Он использует настроенный Record Reader и схему для чтения входного набора записей из тела файла потока, а затем вставляет/обновляет пакеты этих записей в настроенной коллекции MongoDB. Этот процессор не поддерживает удаление. Количество документов для вставки/обновления за один раз контролируется конфигурационным свойством «Batch Size». Это значение должно быть установлено на разумный размер, чтобы гарантировать, что MongoDB не будет перегружен слишком большим количеством операций одновременно.
Теги
mongodb, insert, update, upsert, record, put
Свойства
| Название | Описание |
|---|---|
| Client Service | Если это свойство настроено, оно будет использовать назначенную клиентскую службу для объединения подключений в пул. |
| Mongo Database Name | Имя используемой базы данных Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Mongo Collection Name | Имя используемой коллекции Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Record Reader | Указывает службу контроллера для анализа входящих данных и определения их схемы |
| Batch Size | Количество записей, которые нужно объединить для одной операции вставки/обновления в MongoDB. |
| Ordered | Выполнять упорядоченные или неупорядоченные операции |
| Bypass Validation | Включить или отключить обход проверки схемы документа во время операций вставки или обновления. Обход проверки документа — это привилегированное действие в MongoDB. Включение этого свойства может привести к ошибкам авторизации для пользователей с ограниченными правами. |
| Update Key Fields | Список полей, разделенных запятыми, на основе которых необходимо идентифицировать документы для обновления. Если это свойство задано, NiFi попытается выполнить операцию обновления для всех документов. Если это свойство не зада но, все документы будут вставлены. |
| Update Mode | Выберите между обновлением одного документа или нескольких документов для каждой входящей записи.This Property is only considered if the [Update Key Fields] Property has a value specified. |
Взаимосвязи
- success: Все файлы Flow, которые записываются в MongoDB, направляются в эту связь
- failure: Все файлы Flow, которые не могут быть записаны в MongoDB, направляются в эту связь