Openflow Connector for Salesforce Bulk API:トラブルシューティング

注釈

このコネクタは、 Snowflakeコネクタ規約 に従うものとします。

このトピックでは、 Openflow Connector for Salesforce Bulk API のトラブルシューティング方法について説明します。

モニタリング

SalesforceからSnowflakeに同期されるデータの量を追跡するには、イベントテーブルをクエリします。次のクエリ例は、過去30分間から関連するログを取得します。

SELECT
  timestamp,
  Deployment_ID,
  Runtime_Key,
  parsed_log:level as log_level,
  parsed_log:loggerName as logger,
  parsed_log:formattedMessage as message,
  parsed_log
FROM (
  SELECT
    timestamp,
    resource_attributes:"openflow.dataplane.id" as Deployment_ID,
    resource_attributes:"k8s.namespace.name" as Runtime_Key,
    TRY_PARSE_JSON(value) as parsed_log
  FROM OPENFLOW.TELEMETRY.EVENTS
  WHERE true
    AND timestamp > dateadd('minutes', -30, sysdate())
    AND record_type = 'LOG'
    AND resource_attributes:"k8s.namespace.name" like 'runtime-%'
  ORDER BY timestamp DESC
)
WHERE true
  AND logger = 'org.apache.nifi.processors.standard.LogMessage'
  AND message LIKE '%SALESFORCE_BULK_API%';
Copy

トラブルシューティング

コネクタの問題をトラブルシューティングするには、以下の情報を使用します。

コネクタの状態を確認する

コネクタの状態を調べて、データが期待どおりに複製されていることを確認できます。コネクタは、現在および過去の操作の状態を維持して、Salesforceの変更が欠落しないようにし、失敗が発生した場合に一括ジョブクエリを再試行します。

状態を表示するには、以下を実行します。

  1. キャンバスを右クリックして、 Controller services を選択します。

  2. Salesforce Bulk Jobs State という名前のコントローラーサービスを見つけます。

  3. Salesforce Bulk Jobs State メニューで、 View state をクリックします。

状態は、キーがSalesforceオブジェクトタイプのキー/値のペアのセットです。たとえば、 Account オブジェクトの状態は次の例のようになります。

{"previousLast":"2025-09-30T09:41:23.484406926Z","currentLast":"2025-09-30T09:41:23.484406926Z","status":"COMPLETED"}
Copy

status は、次のいずれかになります。

  • IN_PROGRESS

  • COMPLETED

  • FAILED

  • ABORTED

ステータスが IN_PROGRESS の場合、 FlowFile はそのオブジェクトタイプに対してまだ処理中です。

注意

フローファイルは手動で削除しないでください。これにより、状態を手動で更新できないため、ジョブが IN_PROGRESS ステータスのまま無期限に残る可能性があります。

これが発生した場合は、そのオブジェクトタイプに対して完全な再ロードを実行する必要があります。

指定のオブジェクトタイプにフルロードを強制する

コネクタに1つ以上のオブジェクトタイプのフルリフレッシュを実行するように強制するには、以下を実行します。

  1. フロー内のすべてのプロセッサーを停止します。

  2. 実行中の FlowFiles が処理されていないことを確認してください。

  3. キャンバスを右クリックして、 Disable all controller services を選択します。

  4. Controller services に移動し、 Salesforce Bulk Jobs State という名前のコントローラーサービスの状態を開きます。

  5. 次のアクションのいずれかを実行します。

    • Clear state を選択して、状態全体をクリアします。これにより、コネクタによってフェッチされた すべて の構成オブジェクトタイプのフルロードが強制されます。

    • 特定のオブジェクトタイプの横にあるゴミ箱アイコンを選択すると、特定のオブジェクトタイプの状態のみをクリアします。これにより、コネクタの次の実行時に特定のオブジェクトタイプのフルロードが強制されます。

  6. キャンバスで右クリックし、 Enable all controller services を選択してから、すべてのプロセッサーを起動します。

オブジェクトタイプが IN_PROGRESS ステータスのままである場合

特定のオブジェクトタイプの状態が IN_PROGRESS のままで、そのオブジェクトタイプに実行中の FlowFiles がない場合、ステータスを更新する前に、 FlowFile が手動で削除された可能性があります。

この場合、コネクタがすべてのイベントをキャプチャするように、そのオブジェクトタイプに対してフルロードを実行する必要があります。

状態が IN_PROGRESS のままで、手動で削除された FlowFiles が存在しない場合は、 Snowflakeサポート にお問い合わせください。