QuerySalesforceObject 2025.5.31.15¶

번들¶

org.apache.nifi | nifi-salesforce-nar

설명¶

Salesforce sObject에서 레코드를 검색합니다. 사용자는 ‘Custom WHERE Condition’ 속성을 설정하여 임의의 필터 조건을 추가할 수 있습니다. 프로세서는 사용자 지정 쿼리를 실행할 수도 있지만 이 경우 레코드 처리는 지원되지 않습니다. 증분 검색 지원: 사용자는 ‘Age Field’ 속성에서 레코드가 언제 생성되었는지 확인하는 데 사용할 필드를 정의할 수 있습니다. 이 속성을 설정하면 프로세서가 새 레코드를 검색합니다. 증분 로딩 및 레코드 기반 처리는 속성 기반 쿼리에서만 지원됩니다. 또한 수명에 대한 초기 컷오프 값을 정의하여 첫 번째 실행에서도 오래된 레코드를 모두 필터링할 수 있습니다. ‘Property Based Query’의 경우 이 프로세서는 기본 노드에서만 실행되어야 합니다. FlowFile 특성 ‘record.count’는 얼마나 많은 레코드가 검색되어 출력에 기록되었는지를 나타냅니다. 프로세서는 선택적 입력 FlowFile 을 수락하고 쿼리에서 FlowFile 특성을 참조할 수 있습니다. ‘삭제된 레코드 포함’이 true이면 프로세서는 ‘queryAll’ API 를 사용하여 삭제된 레코드(소프트 삭제)을 결과에 포함시킵니다. 삭제된 레코드를 쿼리할 때 ‘IsDeleted’ 필드가 결과에 자동으로 포함됩니다.

태그¶

query, salesforce, sobject, soql

입력 요구 사항¶

ALLOWED

민감한 동적 속성 지원¶

false

속성¶

속성	설명
age-delay	시간 윈도우의 종료 타임스탬프는 이 속성에 구성된 양만큼 더 일찍 조정됩니다. 예를 들어, 속성 값이 10초인 경우 12:30:45의 종료 타임스탬프는 12:30:35로 변경됩니다.
age-field	제한된 시간 윈도우를 사용하여 레코드를 필터링하는 데 사용할 TIMESTAMP 필드의 이름입니다. 프로세서는 마지막 프로세서 실행 후에 기록된 타임스탬프 값보다 새로운 타임스탬프 값을 가진 레코드만 반환합니다.
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