Pular para o conteúdo principal

Input Cron

Dispara sozinho, em horários ou intervalos fixos, sem depender de ninguém chamar. A cada disparo, uma mensagem é escrita no tópico de saída.

É o Input usado para rotinas: acionar um processo às 3h da manhã, gerar um arquivo por hora, verificar algo a cada cinco minutos.

Campos

CampoO que éPadrão
Expressão CronQuando disparar. Formato minuto hora dia mês dia-da-semana.Uma vez por hora
Corpo (opcional)O conteúdo que cada disparo coloca na mensagem. Se ficar em branco, a mensagem sai sem conteúdo.vazio

Expressões comuns

ExpressãoQuando dispara
*/5 * * * *A cada 5 minutos
0 * * * *No minuto zero de cada hora
0 3 * * *Todo dia às 3h
0 3 * * 1Toda segunda-feira às 3h
30 2 1 * *Todo dia 1º do mês, às 2h30

O que este Input escreve no tópico

ParteConteúdo
ValueExatamente o texto do campo Corpo. Se o campo estiver vazio, o Value vem vazio.
KeyVazia
HeadersNenhum

Exemplo

Com Corpo preenchido com {"evento": "fechamento-diario"} e expressão 0 3 * * *, todo dia às 3h da manhã a mensagem escrita no tópico é:

Key: (vazia)
Value: {"evento": "fechamento-diario"}
Headers: (nenhum)

Com o campo Corpo em branco, a mensagem sai assim:

Key: (vazia)
Value: (vazio)
Headers: (nenhum)

Uma mensagem vazia ainda é uma mensagem — ela chega ao próximo node e serve como sinal de "está na hora". O que a maioria das pipelines faz é ligar um Cron a um Transform, que usa o disparo para ir buscar dados em algum lugar e produzir as mensagens de verdade.

Output de arquivo com Value vazio

Ligar um Cron sem corpo direto a um Output de arquivo (SFTP, SMB, GCS) grava linhas em branco. Preencha o Corpo ou coloque um Transform no meio.

Combinações comuns

QueroMonte assim
Chamar uma API de hora em horaCron → Output HTTP
Gerar um arquivo por diaCron → TransformOutput SFTP
Publicar um sinal periódico para outro sistemaCron → Output Kafka