QuerySalesforceObject 2025.10.2.19¶

번들¶

org.apache.nifi | nifi-salesforce-nar

설명¶

Retrieves records from a Salesforce sObject. Users can add arbitrary filter conditions by setting the ‘Custom WHERE Condition’ property. The processor can also run a custom query, although record processing is not supported in that case. Supports incremental retrieval: users can define a field in the ‘Age Field’ property that will be used to determine when the record was created. When this property is set the processor will retrieve new records. Incremental loading and record-based processing are only supported in property-based queries. It ‘s also possible to define an initial cutoff value for the age, filtering out all older records even for the first run. In case of’Property Based Query ‘this processor should run on the Primary Node only. FlowFile attribute’ record.count ‘indicates how many records were retrieved and written to the output. The processor can accept an optional input FlowFile and reference the FlowFile attributes in the query. When’Include Deleted Records ‘is true, the processor will include deleted records (soft-deletes) in the results by using the’ queryAll ‘API. The’IsDeleted’ field will be automatically included in the results when querying deleted records.

태그¶

query, salesforce, sobject, soql

입력 요구 사항¶

ALLOWED

민감한 동적 속성 지원¶

false

속성¶

속성	설명
age-delay	시간 윈도우의 종료 타임스탬프는 이 속성에 구성된 양만큼 더 일찍 조정됩니다. 예를 들어, 속성 값이 10초인 경우 12:30:45의 종료 타임스탬프는 12:30:35로 변경됩니다.
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.
create-zero-record-files	Salesforce REST API 에서 레코드를 반환하지 않을 때 FlowFile 을 생성할지 여부를 지정합니다
custom-soql-query	실행할 SOQL 쿼리를 지정합니다.
custom-where-condition	쿼리의 WHERE 절에 추가할 사용자 지정 식입니다
field-names	쿼리할 sObject에 요청된 필드 이름의 쉼표로 구분된 목록입니다. 이 필드를 비워두면 모든 필드가 쿼리됩니다.
include-deleted-records	true이면 프로세서는 쿼리 결과에 삭제된 레코드(IsDeleted = true)을 포함합니다. 활성화되면 프로세서는’queryAll’ API 를 사용합니다.
initial-age-filter	이 속성은 프로세서가 첫 번째 쿼리를 실행할 때 적용하는 시작 시간을 지정합니다.
oauth2-access-token-provider	HTTP 인증 헤더를 사용하여 인증하기 위한 OAuth2 액세스 토큰 제공 서비스
쿼리 유형	매개 변수별로 쿼리를 제공하거나 전체 사용자 지정 쿼리를 제공하도록 선택합니다.
read-timeout	Salesforce REST API 에서 응답을 읽는 데 허용되는 최대 시간
record-writer	Salesforce REST API 에서 반환된 레코드 작성에 사용되는 서비스
salesforce-api-version	서비스/데이터 경로 뒤 URL 에 추가되는 Salesforce REST API 의 버전 번호입니다. 지원되는 버전은 Salesforce 설명서를 참조하십시오.
salesforce-url	추가 경로 정보가 없는 도메인을 포함한 Salesforce 인스턴스의 URL (예: https://MyDomainName.my.salesforce.com)
sobject-name	쿼리할 Salesforce sObject

상태 관리¶

범위	설명
CLUSTER	‘수명 필드’를 설정하면 쿼리 실행 후 실행 시간이 저장됩니다. 이후 쿼리에는 추가 조건이 적용되어 저장된 실행 시간보다 최신인 레코드만(‘Age Delay’ 옵션 값으로 조정됨) 검색됩니다. 상태는 클러스터 전체에 저장되므로 이 프로세서는 기본 노드에서만 실행될 수 있으며, 새로운 기본 노드가 선택되면 새 노드는 데이터를 복제하지 않고 이전 노드가 중단한 부분을 이어받을 수 있습니다.

범위

설명

CLUSTER

‘수명 필드’를 설정하면 쿼리 실행 후 실행 시간이 저장됩니다. 이후 쿼리에는 추가 조건이 적용되어 저장된 실행 시간보다 최신인 레코드만(‘Age Delay’ 옵션 값으로 조정됨) 검색됩니다. 상태는 클러스터 전체에 저장되므로 이 프로세서는 기본 노드에서만 실행될 수 있으며, 새로운 기본 노드가 선택되면 새 노드는 데이터를 복제하지 않고 이전 노드가 중단한 부분을 이어받을 수 있습니다.

관계¶

이름	설명
실패	쿼리가 실패하면 입력 flowfile은 이 관계로 전송됩니다.
원본	쿼리가 성공하면 입력 flowfile은 이 관계로 전송됩니다.
성공	성공적인 쿼리 결과로 생성된 FlowFiles 의 경우.

Writes 특성¶

이름	설명
mime.type	Mime.type 특성을 Record Writer가 지정한 MIME 유형으로 설정합니다.
record.count	FlowFile 에 레코드 수를 설정합니다.
total.record.count	FlowFile 에 있는 총 레코드 수를 설정합니다.

참고 항목¶

org.apache.nifi.processors.salesforce.PutSalesforceObject