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
| Campo | O que é | Padrão |
|---|---|---|
| Expressão Cron | Quando 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ão | Quando dispara |
|---|---|
*/5 * * * * | A cada 5 minutos |
0 * * * * | No minuto zero de cada hora |
0 3 * * * | Todo dia às 3h |
0 3 * * 1 | Toda segunda-feira às 3h |
30 2 1 * * | Todo dia 1º do mês, às 2h30 |
O que este Input escreve no tópico
| Parte | Conteúdo |
|---|---|
| Value | Exatamente o texto do campo Corpo. Se o campo estiver vazio, o Value vem vazio. |
| Key | Vazia |
| Headers | Nenhum |
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.
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
| Quero | Monte assim |
|---|---|
| Chamar uma API de hora em hora | Cron → Output HTTP |
| Gerar um arquivo por dia | Cron → Transform → Output SFTP |
| Publicar um sinal periódico para outro sistema | Cron → Output Kafka |