Mensajería y Notificación

AWS Simple Notification System (SNS)

Descripción: el componente AWS SNS permite que se envíen mensajes a un Amazon Simple Notification Topic.
Ejemplo
- El flujo comienza con una solicitud POST en el endpoint /hello.
- Cuando se recibe una solicitud, se envía un mensaje a un tópico del 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)

Descripción: el componente AWS SQS ofrece soporte para el envío y recepción de mensajes al servicio SQS de Amazon.
Ejemplo
- El flujo comienza con una solicitud POST en el endpoint /hello.
- Cuando se recibe una solicitud, se envía un mensaje al servicio SQS de Amazon.

Script

Diagrama

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

Google Pub/Sub

Descripción: el componente Google Pub/Sub permite la integración con el servicio Google Cloud Pub/Sub para publicar y consumir mensajes. Es ideal para la comunicación asincrónica entre aplicaciones, facilitando el intercambio de datos en escenarios distribuidos.
Ejemplo
- La integración se activa mediante una solicitud POST en /my-api.
- El cuerpo del mensaje se transforma a letras mayúsculas (${body.toUpperCase()}) y se le agrega el prefijo "Transformed message: ".
- El mensaje transformado se envía al tema de Google Pub/Sub especificado.
- Los parámetros incluyen:
  - serviceAccountKey: archivo JSON de la cuenta de servicio utilizada para la autenticación.
  - destinationName: nombre del tema en Google Pub/Sub.
- Se registra un log informando que el mensaje fue enviado al tema de 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

Descripción: el componente Kafka se usa para la comunicación con el broker de mensajes Apache Kafka.
Ejemplo
- El flujo se inicia con una solicitude POST en el endpoint /kafka.
- El mensaje recibido se envía a uno o más tópicos Kafka que corresponden al patrón retry*.
- La conexión con Kafka se realiza a través del broker especificado.
- Parámetros de la URI:
  - brokers: "54.207.234.81:38082": especifica la dirección del broker Kafka (en este caso, 54.207.234.81 en el puerto 38082).
  - topicIsPattern: true: indica que el tópico al que se envía el mensaje debe interpretarse como un patrón, permitiendo que se envíen mensajes a todos los tópicos que correspondan al patrón retry*.

Script

Diagrama

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

Paho

Descripción: el componente Paho permite la integración de aplicaciones con el protocolo MQTT, facilitando la comunicación entre dispositivos y sistemas en entornos de Internet de las Cosas (IoT).
Ejemplo
- El flujo comienza con una solicitud GET para el endpoint sensor/temperature.
- El mensaje del sensor es recibido a través del conector Paho (configurado con la URL del broker MQTT: ssl://broker.brokername.com:8883) y enviado al siguiente step.
- El flujo registra el mensaje recibido del sensor MQTT en el log, utilizando la variable ${body} para mostrar el contenido del mensaje.
- Si un mensaje con el contenido "Sensor data: 24°C" es publicado en el tópico sensor/temperature, el 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

Descripción: el componente Paho MQTT5 permite la integración de aplicaciones con el protocolo MQTT (versión 5), ofreciendo funciones avanzadas de mensajería, como sesiones persistentes y control de flujo.
Ejemplo
- El flujo es idéntico al flujo descrito para el componente Paho, con la diferencia de que este usa la versión 5 del 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

Descripción: el componente Slack permite enviar mensajes, notificaciones y alertas a canales o usuarios de Slack directamente desde sus flujos de integración.
Ejemplo
- El flujo realiza una solicitud POST al endpoint /hello.
- Envía la respuesta a un canal en Slack utilizando un token de autenticación.
- Luego, registra un mensaje de confirmación en el log indicando que el mensaje se envió con éxito.

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]