Openflow Connector for Salesforce Bulk API: Solução de problemas

Nota

O conector está sujeito aos Termos do conector Snowflake.

Este tópico descreve como solucionar problemas do Openflow Connector for Salesforce Bulk API.

Monitoramento

Para rastrear a quantidade de dados sincronizados do Salesforce para o Snowflake, consulte a tabela de eventos. A consulta de exemplo a seguir recupera logs relevantes dos últimos 30 minutos:

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

Solução de problemas

Use as informações a seguir para solucionar problemas com o conector.

Verificar o estado do conector

Você pode examinar o estado do conector para garantir que os dados estejam sendo replicados conforme esperado. O conector mantém um estado de operações atuais e passadas para garantir que nenhuma alteração do Salesforce seja perdida e para repetir consultas de trabalhos em massa em caso de falhas.

Para visualizar o estado:

  1. Clique com o botão direito do mouse na tela e selecione Controller services.

  2. Localize o serviço do controlador chamado Salesforce Bulk Jobs State.

  3. No menu Salesforce Bulk Jobs State, clique em View state.

O estado é um conjunto de pares chave/valor em que a chave é o tipo de objeto do Salesforce. Por exemplo, o estado do objeto Account pode ser parecido com o exemplo a seguir:

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

O status pode ser uma das seguintes opções:

  • IN_PROGRESS

  • COMPLETED

  • FAILED

  • ABORTED

Se o status for IN_PROGRESS, um FlowFile ainda está sendo processado para esse tipo de objeto.

Cuidado

Não exclua arquivos de fluxo manualmente. Isso pode fazer com que um trabalho permaneça no status IN_PROGRESS indefinidamente porque o estado não pode ser atualizado manualmente.

Caso isso aconteça, será necessário realizar um recarregamento completo para esse tipo de objeto.

Forçar um carregamento completo para um determinado tipo de objeto

Para forçar o conector a executar uma atualização completa para um ou mais tipos de objetos:

  1. Interrompa todos os processadores no fluxo.

  2. Certifique-se de que não há FlowFiles sendo processados.

  3. Clique com o botão direito do mouse na tela e selecione Disable all controller services.

  4. Acesse Controller services e abra o estado do serviço do controlador chamado Salesforce Bulk Jobs State.

  5. Execute uma das seguintes ações:

    • Selecione Clear state para limpar todo o estado. Isso força um carregamento completo para todos os tipos de objetos configurados buscados pelo conector.

    • Selecione o ícone de lixeira ao lado de um tipo de objeto específico para limpar o estado apenas para um tipo de objeto específico. Isso força um carregamento completo desse tipo de objeto específico durante a próxima execução do conector.

  6. Na tela, clique com o botão direito do mouse, selecione Enable all controller services e inicie todos os processadores.

Se um tipo de objeto permanecer no status IN_PROGRESS

Se o estado de um determinado tipo de objeto estiver preso em IN_PROGRESS e não haja FlowFiles em execução para esse tipo de objeto, pode ser que um FlowFile tenha sido excluído manualmente antes de atualizar o status.

Nesse caso, você deve executar um carregamento completo para esse tipo de objeto para garantir que o conector capture todos os eventos.

Se o estado estiver preso em IN_PROGRESS mas não houve exclusão manual de FlowFiles entre em contato com o Suporte Snowflake.