SubmitQueryJob 2025.5.31.15¶
バンドル¶
com.snowflake.openflow.runtime | runtime-salesforce-processors-nar
説明¶
Bulk API 2.0 を使用して Salesforce にクエリジョブを送信します。
入力要件¶
ALLOWED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
列の区切り文字 |
CSV ジョブデータに使用される列区切り文字。 |
構成モード |
このプロセッサーを構成するための構成モード。詳細モードを使用する場合、 SOQL クエリを提供する必要があり、processor の状態は、クエリされたオブジェクトに関係なく、最後にクエリジョブを投入した時のタイムスタンプのみを保存します。シンプル・モードを使用する場合、オブジェクト名とクエリされるフィールドを提供する必要があり、プロセッサーの状態には、クエリされる各オブジェクトの最後のクエリ・ジョブ投入のタイムスタンプが格納されます。 |
インクリメンタル・オフロード |
プロセッサーがインクリメンタルオフロードを実行するかどうか。True の場合、プロセッサーは、 SystemModstamp フィールドの WHERE 句を使用して、最後のクエリ・ジョブ送信以降に変更された記録のみをフェッチします。 |
行末 |
CSV ジョブデータで使用される行末。データ行の終わりを示します。 |
オブジェクトフィールド |
指定されたオブジェクトのクエリ対象のフィールド名のカンマ区切りリスト。 |
オブジェクト名 |
クエリするオブジェクトの名前。 |
操作 |
送信するクエリのタイプ。 |
クエリ |
実行するクエリ。インクリメンタルな検索 (つまり、最後にクエリを送信してから追加/変更/削除された要素のみが検索される) を実行するために、このプロセッサーは ${nowTs} と ${lastJobTimestamp} の2つの属性を公開しています。SELECT Id FROM アカウント WHERE SystemModstamp > ${lastJobTimestamp} AND SystemModstamp <= ${nowTs}。 |
結果形式 |
結果に使用する形式。現在、サポートされる値は CSV のみです。 |
Salesforceクライアント |
APIs と対話するための Salesforce クライアント |
状態管理¶
スコープ |
説明 |
|---|---|
CLUSTER |
クエリフィールドでインクリメンタルリトリーバル用のプレースホルダーが使用されている場合、最後のクエリジョブ送信時刻から30秒を引いたタイムスタンプが状態に保存されます。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
comms.failure |
クエリジョブが投入されなかった場合、 FlowFile はこのリレーションシップにルーティングされます。 |
failure |
クエリジョブが送信できなかった場合、 FlowFile がこのリレーションシップにルーティングされます。 |
success |
クエリジョブが正常に送信されると、 FlowFile がこのリレーションシップにルーティングされます。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
jobId |
ジョブ用の一意の ID。 |
operationType |
クエリのタイプ。 |
objectType |
クエリ対象のオブジェクトタイプ。 |
createdById |
ジョブを作成したユーザーの ID。 |
createdDate |
ジョブが作成された UTC 日時。 |
systemModstamp |
API が最後にジョブ情報を更新した UTC の日時。 |
jobState |
ジョブの現在の処理状態。 |
concurrencyMode |
リクエストの処理方法。 |
contentType |
結果に使用する形式。 |
apiVersion |
ジョブが作成された API バージョン。 |
lineEnding |
CSV ジョブデータで使用される行末。データ行の終わりを示します。 |
columnDelimiter |
CSV ジョブデータに使用される列区切り文字。 |
ユースケース¶
Bulk API 2.0 を使用して Salesforce にクエリジョブを送信します。 |