SubmitQueryJob 2025.10.2.19¶

バンドル¶

com.snowflake.openflow.runtime | runtime-salesforce-processors-nar

説明¶

Bulk API 2.0を使用してSalesforceにクエリジョブを送信します。SIMPLE モードでは、オブジェクトごとの状態（previousLast/currentLastとステータス）が、構成済みのコントローラーサービスに格納されます。ADVANCED モードでは、オブジェクト間のインクリメンタルクエリをサポートするために、プロセッサースコープに単一の「最後の」タイムスタンプが格納されます。

タグ¶

bulk, job, preview, query, salesforce

入力要件¶

ALLOWED

機密動的プロパティをサポート¶

false

プロパティ¶

プロパティ	説明
列の区切り文字	CSV ジョブデータに使用される列区切り文字。
構成モード	The configuration mode for configuring this processor. If using advanced mode, the SOQL query has to be provided and the processor 's state will only store the timestamp of the last query job submission regardless of the object queried. If using simple mode, the object name and the fields to be queried have to be provided and the processor's state will store the timestamp of the last query job submission for each object queried.
インクリメンタル・オフロード	Whether the processor should perform incremental offload. If true, the processor will only fetch the records that have been modified since the last query job submission by using a WHERE clause on the SystemModstamp field.
行末	CSV ジョブデータで使用される行末。データ行の終わりを示します。
オブジェクトフィールド	指定されたオブジェクトのクエリ対象のフィールド名のカンマ区切りリスト。
オブジェクト名	クエリするオブジェクトの名前。
操作	送信するクエリのタイプ。
クエリ	The query to be performed. In order to perform incremental retrieval (ie. only the added/modified/deleted elements since the last submission of the query are retrieved), this processor exposes two attributes: ${nowTs} and ${lastJobTimestamp}. It is possible to use those placeholders like SELECT Id FROM Account WHERE SystemModstamp > ${lastJobTimestamp} AND SystemModstamp <= ${nowTs}.
結果形式	結果に使用する形式。現在、サポートされる値は CSV のみです。
Salesforce一括ジョブ状態サービス	オブジェクトタイプごとにバルクジョブの状態を格納するコントローラーサービス（SIMPLE モードで使用）。ADVANCED モードでは、プロセッサーはプロセッサーの状態に1つの「最後の」タイムスタンプを格納します。
Salesforceクライアント	APIs と対話するための Salesforce クライアント

状態管理¶

スコープ	説明
CLUSTER	クエリフィールドでインクリメンタルリトリーバル用のプレースホルダーが使用されている場合、最後のクエリジョブ送信時刻から30秒を引いたタイムスタンプが状態に保存されます。

リレーションシップ¶

名前	説明
comms.failure	クエリジョブが投入されなかった場合、 FlowFile はこのリレーションシップにルーティングされます。
failure	クエリジョブが送信できなかった場合、 FlowFile がこのリレーションシップにルーティングされます。
in.progress	An incoming FlowFile is routed to this relationship when a previous job for the same object is still IN_PROGRESS
success	クエリジョブが正常に送信されると、 FlowFile がこのリレーションシップにルーティングされます。

属性の書き込み¶

名前	説明
jobId	ジョブ用の一意の ID。
operationType	クエリのタイプ。
objectType	クエリ対象のオブジェクトタイプ。
createdById	ジョブを作成したユーザーの ID。
createdDate	ジョブが作成された UTC 日時。
systemModstamp	API が最後にジョブ情報を更新した UTC の日時。
jobState	ジョブの現在の処理状態。
concurrencyMode	リクエストの処理方法。
contentType	結果に使用する形式。
apiVersion	ジョブが作成された API バージョン。
lineEnding	CSV ジョブデータで使用される行末。データ行の終わりを示します。
columnDelimiter	CSV ジョブデータに使用される列区切り文字。
nowTs	クエリジョブを構築するために WHERE 句で使用される時間範囲の上限。
lastJobTimestamp	クエリジョブを構築するために WHERE 句で使用される時間範囲の下限。

ユースケース¶

Bulk API 2.0 を使用して Salesforce にクエリジョブを送信します。