SubmitQueryJob 2025.10.2.19¶

バンドル¶

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

説明¶

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

タグ¶

一括、ジョブ、プレビュー、クエリ、salesforce

入力要件¶

ALLOWED

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

false

プロパティ¶

プロパティ	説明
列の区切り文字	CSV ジョブデータに使用される列区切り文字。
構成モード	このプロセッサを構成するための構成モード。詳細モードを使用する場合、SOQL クエリを提供する必要があり、プロセッサーの状態は、クエリされたオブジェクトに関係なく、最後にクエリジョブが送信されたタイムスタンプのみを格納します。シンプルモードを使用する場合、オブジェクト名とクエリされるフィールドを提供する必要があり、プロセッサーの状態は、クエリされる各オブジェクトの最後のクエリジョブ送信のタイムスタンプを格納します。
インクリメンタル・オフロード	プロセッサーがインクリメンタルオフロードを実行するかどうか。trueの場合、SystemModstamp フィールドで WHERE 句を使用することで、プロセッサーは最後のクエリジョブ送信以降に変更されたレコードのみをフェッチします。
行末	CSV ジョブデータで使用される行末。データ行の終わりを示します。
オブジェクトフィールド	指定されたオブジェクトのクエリ対象のフィールド名のカンマ区切りリスト。
オブジェクト名	クエリするオブジェクトの名前。
操作	送信するクエリのタイプ。
クエリ	実行されるクエリ。増分を取得する（つまり、最後にクエリを送信してから追加/変更/削除された要素のみを検索する）ために、このプロセッサーは${nowTs}と${lastJobTimestamp}という2つの属性を公開しています。これらのプレースホルダーは、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	同じオブジェクトに対する以前のジョブがまだ IN_PROGRESS である場合、着信 FlowFile はこのリレーションシップにルーティングされます。
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 にクエリジョブを送信します。