Перейти к основному содержимому

PutMongo

Описание

Записывает содержимое файла потока в MongoDB.

Теги

mongodb, insert, update, write, put

Свойства

НазваниеОписание
Client ServiceЕсли это свойство настроено, оно будет использовать назначенную клиентскую службу для объединения подключений в пул.
Mongo Database NameИмя используемой базы данных Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)
Mongo Collection NameИмя используемой коллекции Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)
ModeУказывает, должен ли процессор вставлять или обновлять содержимое
UpsertЕсли значение равно true, вставляет документ, если ни один документ не соответствует критериям запроса на обновление; это свойство допустимо только при использовании режима обновления, в противном случае оно игнорируется
Update Query KeyИмя ключа, используемого для построения критериев запроса на обновление; это свойство допустимо только при использовании режима обновления, в противном случае оно игнорируется. Пример: _id Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)
Update QueryУкажите полный запрос MongoDB, используемый для запроса поиска для обновления/вставки. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)
Update ModeChoose an update mode. You can either supply a JSON document to use as a direct replacement or specify a document that contains update operators like $set, $unset, and $inc. When Operators mode is enabled, the flowfile content is expected to be the operator part for example: {$set:{"key": "value"},$inc:{"count":1234}} and the update query will come from the configured Update Query property.
Character SetНабор символов, в котором кодируются данные

Взаимосвязи

  • success: Все файлы Flow, которые записываются в MongoDB, направляются в эту связь
  • failure: Все файлы Flow, которые не могут быть записаны в MongoDB, направляются в эту связь