SubmitQueryJob 2025.5.31.15¶
Pacote¶
com.snowflake.openflow.runtime | runtime-salesforce-processors-nar
Descrição¶
Envia um trabalho de consulta ao Salesforce usando a Bulk API 2.0.
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 para definir esse processador. Se estiver usando o modo avançado, a consulta SOQL deverá ser fornecida e o estado do processador armazenará apenas o carimbo de data/hora do envio do último 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 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 executar 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 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. |
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 |
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. |
Casos de uso¶
Envia um trabalho de consulta ao Salesforce usando a Bulk API 2.0. |