sofka-mqtt-publisher-module v1.0.0

MQTT Publisher Module

Librería para publicar en el broker MQ el esquema JSON para llenar el formato de logs Compensar

Como usar:

Para utilizar el la librería primero se debe de crear tener los siguientes prerrequisitos:

Host MQ:

Es la URL que expone el MQ para realizar las peticiones.

const mqHost = 'mqtts://b-b3a0a730-03e2-4449-8d0b-e9d697ae3811-2.mq.us-east-2.amazonaws.com';

Options:

Son las parámetros necesarios para realizar la autenticación y conexión en el MQ

const options = {
    username: 'user',
    password: 'C0mp3ns4r',
    clientId: 'lambda',
    port: 8883
};

• username: Usuario creado en el MQ para identificarse.
• password: Contraseña creada en el MQ para identificarse.
• clientId: Identificador del cliente que realiza el registro en el MQ.
• port: Puerto que expone el MQ para la conexión.

Inicializar la librería:

Se crea una instancia de la librería enviando los parámetros (URL, Opciones) requeridos para poder usar la librería.

const publisher = new mqttPlublisherModule(mqHost , options);
.then (data => console.log(data))
.catch(error => console.log(error));

Respuesta:

Exitosa:

Realiza el registro dentro del tópico en el MQ.

{
	'statusCode': 200,
	'body':  'published on api_..._lambda'
}

Erronea:

Retorna el código de error y un mensaje descriptivo.

{
	'statusCode': 401,
	'body':  'Connection refused: Not authorized'
}

Licencia

ISC