Reprocessamento

[lucasuyemura]

Gostaria de saber como funciona o reprocessamento a no app Integration, por exemplo, no meu caso, eu tenho um fluxo que envia informações de uma consulta gerada no banco por dados, imagine que um dia a integração não rode por algum motivo específico, queria saber como faço para reprocessar somente os dias em que a integração ficou fora?

[AlexET]

Olá @lucasuyemura,

Notamos que sua pergunta ainda não foi respondida, mas vamos mantê-la em nosso radar e entrar em contato com outros membros da comunidade para que possam contribuir.

[carloscabral]

Existem várias estratégias para a re-execução de integrações.

 - Implementação de retentativas https://cloud.google.com/application-integration/docs/error-handling-strategy - no nível da task (por exemplo, a task de escrita ao banco no seu exemplo) ou mesmo retentar a integração como um todo

- Re-execução manual o via API através da feature de replay - https://cloud.google.com/application-integration/docs/replay-executions - Adicionalmente, em roadmap, a execução do replay permitirá atualizar os parâmetros de input para a re-execução

- Implementar uma estratégia automatizada de DLQ usando PubSub - basicamente, quando a retentativa no nível de task falha, você pode publicar a mensagem/input em uma fila de DLQ (dead letter queue) do PubSub. Uma outra integração, geralmente no formato de schedule, processa as integrações na fila de DLQ novamente.