QuerySalesforceObject
Описание
Извлекает записи из объекта Salesforce sObject. Пользователи могут добавлять произвольные условия фильтрации, установив свойство 'Custom WHERE Condition'. Процессор также может выполнить пользовательский запрос, хотя в этом случае обработка записей не поддерживается. Поддерживает инкрементальное извлечение: пользователи могут определить поле в свойстве 'Age Field', которое будет использоваться для определения времени создания записи. При установке этого свойства процессор будет извлекать новые записи. Инкрементальная загрузка и обработка записей поддерживаются только в запросах на основе свойств. Также возможно задать начальное значение отсечки для возраста, фильтруя все старые записи, даже для первого запуска. В случае 'Property Based Query' этот процессор должен выполняться только на основном узле. Атрибут файла потока 'record.count' указывает, сколько записей было извлечено и записано в вывод. Процессор может принимать необязательный входной файл потока и ссылаться на его атрибуты в запросе.
Теги
salesforce, sobject, soql, query
Свойства
| Название | Описание |
|---|---|
| Salesforce Instance URL | URL-адрес экземпляра Salesforce, включая домен без дополнительной информации о пути, например https://MyDomainName.my.salesforce.com Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| API Version | The version number of the Salesforce REST API appended to the URL after the services/data path. See Salesforce documentation for supported versions Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Query Type | Выберите запрос по параметрам или полный пользовательский запрос. |
| Custom SOQL Query | Укажите SOQL-запрос для выполнения. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)This Property is only considered if the [Query Type] Property has a value of "Custom Query". |
| sObject Name | Объект Salesforce, к которому будет выполнен запрос Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)This Property is only considered if the [Query Type] Property has a value of "Property Based Query". |
| Field Names | Список имен полей, разделенных запятыми, которые запрашиваются у sObject для выполнения запроса. Если это поле оставить пустым, будут запрошены все поля. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)This Property is only considered if the [Query Type] Property has a value of "Property Based Query". |
| Record Writer | Сервис, используемый для записи записей, возвращаемых из Salesforce REST APIThis Property is only considered if the [Query Type] Property has a value of "Property Based Query". |
| Age Field | The name of a TIMESTAMP field that will be used to filter records using a bounded time window.The processor will return only those records with a timestamp value newer than the timestamp recorded after the last processor run. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)This Property is only considered if the [Query Type] Property has a value of "Property Based Query". |
| Initial Age Start Time | Это свойство определяет время начала, которое про цессор применяет при выполнении первого запроса. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)This Property is only considered if all of the following conditions are met:The [Query Type] Property has a value of "Property Based Query".The [Age Field] Property has a value specified. |
| Age Delay | Конечная метка времени временного окна будет скорректирована на величину, заданную в этом свойстве. Например, при значении свойства 10 секунд конечная метка времени 12:30:45 будет изменена на 12:30:35. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)This Property is only considered if all of the following conditions are met:The [Query Type] Property has a value of "Property Based Query".The [Age Field] Property has a value specified. |
| Custom WHERE Condition | Пользовательское выражение, которое нужно добавить в предложение WHERE запроса Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)This Property is only considered if the [Query Type] Property has a value of "Property Based Query". |
| Read Timeout | Максимальное время, допустимое для чтения ответа от Salesforce REST API Поддерживает язык выражений: true (будет оценива ться только с использованием переменных среды) |
| Create Zero Record FlowFiles | Указывает, следует ли создавать FlowFile, если Salesforce REST API не возвращает никаких записейThis Property is only considered if the [Query Type] Property has a value of "Property Based Query". |
| OAuth2 Access Token Provider | Сервис, предоставляющий токены доступа OAuth2 для аутентификации с использованием заголовка HTTP Authorization |
Взаимосвязи
- success: Для файлов потока, созданных в результате успешного запроса.
- failure: Входной файл потока отправляется в эту связь при неудачном запросе.
- original: Входной файл потока отправляется в эту связь при успешном запросе.