SubmitQueryJob 2025.10.2.19¶

Pacote¶

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

Descrição¶

Envia um trabalho de consulta ao Salesforce usando a API Bulk 2.0. No modo SIMPLE, o estado por objeto (previousLast/currentLast e status) é armazenado no serviço de controlador configurado. No modo ADVANCED, um único “último” carimbo de data/hora é armazenado no escopo do processador para oferecer suporte a consultas incrementais em objetos.

Tags¶

em massa, trabalho, versão preliminar, consulta, salesforce

Requisito de entrada¶

ALLOWED

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
Delimitador de coluna	O delimitador de coluna usado para dados de trabalho CSV.
Modo de configuração	O modo de configuração desse processador. Se estiver usando o modo avançado, a consulta SOQL deve ser fornecida e o estado do processador armazenará apenas o carimbo de data/hora do último envio do trabalho de consulta, independentemente do objeto consultado. Se estiver usando o modo simples, o nome do objeto e os campos a serem consultados deverão ser fornecidos e o estado do processador armazenará o carimbo de data/hora do último envio do trabalho de consulta para cada objeto consultado.
Descarregamento incremental	Se o processador deve executar o descarregamento incremental. Se verdadeiro, o processador buscará apenas os registros que foram modificados desde o último envio do trabalho de consulta usando uma cláusula WHERE no campo SystemModstamp.
Fim da linha	O fim da linha usado para os dados do trabalho CSV, marcando o final de uma linha de dados.
Campos de objeto	Lista separada por vírgulas do nome dos campos a serem consultados para o objeto especificado.
Nome do objeto	O nome do objeto a ser consultado.
Operação	O tipo de consulta a ser enviado.
Consulta	A consulta a ser realizada. Para realizar a recuperação incremental (ou seja, somente os elementos adicionados/modificados/excluídos desde o último envio da consulta são recuperados), esse processador expõe dois atributos: ${nowTs} e ${lastJobTimestamp}. É possível usar esses espaços reservados como SELECT ID FROM Conta WHERE SystemModstamp > ${lastJobTimestamp} AND SystemModstamp <= ${nowTs}.
Formato do resultado	O formato a ser usado para os resultados. Atualmente, o único valor compatível é CSV.
Serviço de estado do trabalho em massa do Salesforce	Serviço de controlador para armazenar o estado dos trabalhos em massa por tipo de objeto (usado no modo SIMPLE). No modo ADVANCED, o processador armazena um único carimbo de data/hora do “último” no estado do processador.
Cliente Salesforce	Cliente Salesforce para interagir com as APIs

Gerenciamento do estado¶

Escopos	Descrição
CLUSTER	Caso os espaços reservados para a recuperação incremental sejam usados no campo de consulta, o carimbo de data/hora do último envio do trabalho de consulta menos 30 segundos será armazenado no estado.

Relações¶

Nome	Descrição
comms.failure	Um FlowFile de entrada é encaminhado para essa relação se não for possível enviar o trabalho de consulta, mas a operação pode ser tentada novamente
failure	Um FlowFile de entrada é encaminhado para essa relação se o trabalho de consulta não puder ser enviado
in.progress	Um FlowFile recebido é encaminhado para esse relacionamento quando um trabalho anterior para o mesmo objeto ainda está IN_PROGRESS
success	Quando um trabalho de consulta é enviado com sucesso, um FlowFile é encaminhado para essa relação

Grava atributos¶

Nome	Descrição
jobId	O ID exclusivo para esse trabalho.
operationType	O tipo de consulta.
objectType	O tipo de objeto sendo consultado.
createdById	O ID de usuário que criou o trabalho.
createdDate	A data e hora UTC em que o trabalho foi criado.
systemModstamp	A data e hora em UTC que a API atualizou as informações do trabalho pela última vez.
jobState	O estado atual do processamento do trabalho.
concurrencyMode	Como a solicitação é processada.
contentType	O formato a ser usado para os resultados.
apiVersion	A versão da API em que o trabalho foi criado.
lineEnding	O fim da linha usado para os dados do trabalho CSV, marcando o final de uma linha de dados.
columnDelimiter	O delimitador de coluna usado para dados de trabalho CSV.
nowTs	Limite superior do período usado na cláusula WHERE para criar o trabalho de consulta.
lastJobTimestamp	Limite inferior do período usado na cláusula WHERE para criar o trabalho de consulta.

Casos de uso¶

Envia um trabalho de consulta ao Salesforce usando a Bulk API 2.0.