Mensageria e Notificação

AWS Simple Notification System (SNS)

Descrição: o componente AWS SNS permite que mensagens sejam enviadas para um Amazon Simple Notification Topic.
Exemplo
- O fluxo começa com uma requisição POST no endpoint /hello.
- Quando uma requisição é recebida, uma mensagem é enviada para um tópico do AWS Simple Notification Service (SNS).

Script

Diagrama

- from:
    uri: "rest:post:/hello"
    steps:
    - to:
        uri: "aws2-sns:topicNaneOrArn"
        parameters:
          accessKey: "{{accessKey}}"
          secretKey: "{{secretKey}}"

AWS Simple Queue Service (SQS)

Descrição: o componente AWS SQS oferece suporte ao envio e recebimento de mensagens para o serviço SQS da Amazon.
Exemplo
- O fluxo começa com uma requisição POST no endpoint /hello.
- Quando uma requisição é recebida, uma mensagem é enviada para o serviço SQS da Amazon.

Script

Diagrama

- from:
    uri: "rest:post:/hello"
    steps:
    - to:
        uri: "aws2-sqs:queueNameOrArn"
        parameters:
          accessKey: "{{accessKey}}"
          secretKey: "{{secretKey}}"

Google Pub/Sub

Descrição: o componente Google Pub/Sub permite a integração com o serviço Google Cloud Pub/Sub para publicar e consumir mensagens. Ele é ideal para comunicação assíncrona entre aplicações, facilitando a troca de dados em cenários distribuídos.
Exemplo
- A integração é acionada por uma requisição POST em /my-api.
- O corpo da mensagem é transformado para letras maiúsculas (${body.toUpperCase()}) e prefixado com "Transformed message: ".
- A mensagem transformada é enviada para o tópico do Google Pub/Sub especificado.
- Os parâmetros incluem:
  - serviceAccountKey: arquivo JSON da conta de serviço usada para autenticação.
  - destinationName: nome do tópico no Google Pub/Sub.
- Um log é registrado informando que a mensagem foi enviada para o tópico do Pub/Sub.

Script

Diagrama

- from:
    id: rest-trigger-123456
    uri: "rest:post:/my-api"
    steps:
      - setBody:
          id: setBody-2320563641
          simple: 'Transformed message: ${body.toUpperCase()}'
      - to:
          uri: google-pubsub:my-project:my-topic
          parameters:
            serviceAccountKey: service-account.json
            destinationName: my-topic
      - log:
          id: log-2088714838
          message: 'Message sent to Pub/Sub topic: ${body}'

Kafka

Descrição: o componente Kafka é usado para comunicação com o broker de mensagens Apache Kafka.
Exemplo
- O fluxo se inicia com uma requisição POST no endpoint /kafka.
- A mensagem recebida é então enviada para um ou mais tópicos Kafka que correspondem ao padrão retry*.
- A conexão com o Kafka é feita através do broker especificado.
- Parâmetros da URI:
  - brokers: "54.207.234.81:38082": especifica o endereço do broker Kafka (neste caso, 54.207.234.81 na porta 38082).
  - topicIsPattern: true: indica que o tópico para onde a mensagem está sendo enviada deve ser interpretado como um padrão, permitindo que mensagens sejam enviadas para todos os tópicos que correspondem ao padrão retry*.

Script

Diagrama

- from:
    uri: "rest:post:/kafka"
    steps:
    - to:
        uri: "kafka:retry*"
        parameters:
          brokers: "54.207.234.81:38082"
          topicIsPattern: true

Paho

Descrição: o componente Paho permite a integração de aplicações com o protocolo MQTT, facilitando a comunicação entre dispositivos e sistemas em ambientes de Internet das Coisas (IoT).
Exemplo
- O fluxo começa com uma requisição GET para o endpoint sensor/temperature.
- A mensagem do sensor é recebida por meio do conector Paho (configurado com a URL do broker MQTT: ssl://broker.brokername.com:8883) e enviada para o próximo step.
- O fluxo registra a mensagem recebida do sensor MQTT no log, utilizando a variável ${body} para exibir o conteúdo da mensagem.
- Se uma mensagem com o conteúdo "Sensor data: 24°C" for publicada no tópico sensor/temperature, o log registrará: "Got message Sensor data: 24°C".

Script

Diagrama

- from:
    uri: "rest:get:/sensor/temperature"
    steps:
      - to:
          uri: "paho:sensor/temperature"
          parameters:
            brokerUrl: "ssl://broker.brokername.com:8883"
      - log:
          message: "Got message ${body}"

Paho MQTT5

Descrição: o componente Paho MQTT5 permite a integração de aplicações com o protocolo MQTT (versão 5), oferecendo recursos avançados de mensageria, como sessões persistentes e controle de fluxo.
Exemplo
- O fluxo é idêntico ao fluxo descrito para o componente Paho, com a diferença de que este usa a versão 5 do protocolo MQTT.

Script

Diagrama

- from:
    uri: "rest:get:/sensor/temperature"
    steps:
      - to:
          uri: "paho-mqtt5:sensor/temperature"
          parameters:
            brokerUrl: "ssl://broker.brokername.com:8883"
      - log:
          message: "Got message ${body}"

Slack

Descrição: o componente Slack permite que você envie mensagens, notificações e alertas para canais ou usuários do Slack diretamente de seus fluxos de integração.
Exemplo
- O fluxo faz uma requisição POST para o endpoint /hello.
- Envia a resposta para um canal no Slack usando um token de autenticação.
- Em seguida, registra uma mensagem de confirmação no log indicando que a mensagem foi enviada com sucesso.

Script

Diagrama

- from:
    uri: "rest:post:/hello"
    steps:
      - to:
          uri: "slack:#channel"
          parameters:
            token: "your-slack-token"
      - log:
          message: "Message successfully sent to Slack: ${body}"

Thanks for your feedback!

EDIT

Share your suggestions with us!
Click here and then [+ Submit idea]