PutAzureCosmosDBRecord
Описание
Этот процессор поддерживает запись данных в Cosmos DB с использованием Core SQL API. Он использует настроенный считыватель записей и схему для чтения набора записей из тела FlowFile и затем вставляет эти записи в настроенный контейнер Cosmos DB.
Теги
azure, cosmos, insert, record, put
Свойства
| Название | Описание |
|---|---|
| Cosmos DB Connection Service | Если настроено, служба контроллера, используемая для получения строки подключения и ключа доступа. |
| Cosmos DB URI | URI базы данных Cosmos DB, обычно в формате https://{имя_базы_данных}.documents.azure.com:443/ Обратите внимание, что этот URL-адрес предназначен для базы данных Cosmos DB с API Core SQL на портале Azure (Обзор -> URI) Чувствительный параметр: true |
| Cosmos DB Access Key | Ключ доступа к базе данных Cosmos DB на портале Azure (Настройки -> Ключи). Выберите ключ для чтения и записи, чтобы включить создание базы данных или контейнера во время выполнения Чувствительный параметр: true |
| Cosmos DB Consistency Level | Выберите один из пяти уровней согласованности. Ознакомьтесь с различиями между ними в документации по Cosmos DB |
| Cosmos DB Name | Имя или идентификатор базы данных. Это используется в качестве пространства имён для коллекций документов или контейнеров |
| Cosmos DB Container ID | Уникальный идентификатор контейнера |
| Cosmos DB Partition Key | Ключ раздела, используемый для распределения данных между серверами |
| Record Reader | Указывает службу контроллера, используемую для анализа входящих данных и определения их схемы |
| Insert Batch Size | Количество записей, которые нужно сгруппировать для одной операции вставки в Cosmos DB |
| Cosmos DB Conflict Handling Strategy | Выберите, следует ли игнорировать или обновлять запись при возникновении ошибки конфликта во время вставки |
Взаимосвязи
- failure: Все файлы Flow, которые не могут быть записаны в Cosmos DB, направляются в эту связь.
- success: Все файлы Flow, которые записываются в Cosmos DB, направляются в эту связь.