Configuração de Saída

Para utilização do Firehose é requisito realizar a configuração da sindicação de destino antes de iniciar o envio de mensagens para serem processadas.

Para isso, nesta versão, temos os seguintes outputs disponíveis:

• HTTP

• SFTP

• Kafka

• SQL

• AWS Kinesis

• AWS S3

• Azure Blob Storage

• Tabela DeltaLake

• E-Mail

• E-Mail Transacional

• Google Cloud Pub/Sub

• Google Cloud Storage

• Elasticsearch

• MongoDB

• Firehose

Cada mensagem entregue possui um <firehose_correlation_uuid> que é um identificador único da mensagem utilizado internamente pelo Firehose para controle de idempotência.

Parâmetros

É possível configurar um rate limit que será aplicado na entrega na sindicância de destino, permitindo uma quantidade máxima de mensagens em uma determinada janela de tempo.

Indicamos o uso dessa configuração apenas se a sindicância de destino possuir alguma limitação baixa de carga.

Campo	Descrição	Valor
output.description	Descrição do estágio de saída	Tipo: string
output.rate_limit	Configuração de rate limit	Tipo: object Padrão: {}
output.rate_limit.count	Quantidade máxima de mensagens	Tipo: long Obrigatório
output.rate_limit.interval_seconds	Janela de tempo em segundos	Tipo: long Obrigatório

Requisição

Exemplo de requisição:

curl --location '<HOST>/v1/configs' \
  --header 'Content-Type: application/json' \
  --header 'Authorization: <ACCESS-TOKEN>' \
  --data '{
    "output": {
      ...
      "description": "OUTPUT-DESCRIPTION",
      "rate_limit": {
        "count": 1000,
        "interval_seconds": 1
      }
    }
  }'