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.
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 |
The configuration mode for configuring this processor. If using advanced mode, the SOQL query has to be provided and the processor “s state will only store the timestamp of the last query job submission regardless of the object queried. If using simple mode, the object name and the fields to be queried have to be provided and the processor’s state will store the timestamp of the last query job submission for each object queried. |
Descarregamento incremental |
Whether the processor should perform incremental offload. If true, the processor will only fetch the records that have been modified since the last query job submission by using a WHERE clause on the SystemModstamp field. |
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 |
The query to be performed. In order to perform incremental retrieval (ie. only the added/modified/deleted elements since the last submission of the query are retrieved), this processor exposes two attributes: ${nowTs} and ${lastJobTimestamp}. It is possible to use those placeholders like SELECT Id FROM Account 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 |
An incoming FlowFile is routed to this relationship when a previous job for the same object is still 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. |