openfaas / mqtt-connector Goto Github PK

My actions before raising this issue

• Followed the troubleshooting guide
• Read/searched the docs
• Searched past issues

Expected Behaviour

This connector cannot deal with more than one MQTT topic, as stated in https://github.com/openfaas/mqtt-connector/tree/master/chart/mqtt-connector and confirmed by my own tests with the connector. This seems normal as only one MQTT subscription is created. I'm wondering why this connector is limited to one single topic per instance.

Current Behaviour

Only one topic is allowed. If more than one topic are used (e.g. my-topic,my-second-topic), no errors are thrown but only the first topic seems to be used. Only messages published to the first topic my-topic will be received by the connector.

Possible Solution

I've added very simple multi-topic support using multiple subscriptions, but maybe I'm missing how the connector-sdk handles/splits the topic internally.

Your Environment

• FaaS-CLI version ( Full output from: faas-cli version ):
  commit: c12d57c39ac4cc6eef3c9bba2fb45113d882432f
  version: 0.12.14

• Docker version docker version (e.g. Docker 17.0.05 ): Docker 19.03.12

• Are you using Docker Swarm or Kubernetes (FaaS-netes)? No

• Operating System and version (e.g. Linux, Windows, MacOS): Linux

Expected Behaviour

Upgrade to Go 1.18 in GitHub Actions and Dockerfile

Current Behaviour

Currently on Go 1.15

Is it possible to set the "qos:1" and "clean:true" attributes in value.yaml?
I don't know go language，help

My actions before raising this issue

Published an image in to "/testmqtt/pushimage1" MQTT topic
It will trigger another function "mqttsubscribeimage"

Expected Behaviour

"received_image.jpg" should be expected inside the pod

Current Behaviour

Not able to find the "received_image.jpg".

Steps to Reproduce (for bugs)

mqttsubscribeimage function handler code (handler.py) (python3-flask-debian docker file used)
.........................................................................................

from PIL import Image
import io
import json
import os
import uuid
import time
import paho.mqtt.client as mqtt

def on_message(client, userdata, message):

open('received_image.jpg','wb').write(message.payload)

def handle(req):

client = mqtt.Client("ipaddress_of_my_system:1883", transport="tcp")

broker = "ipaddress_of_my_system"
port = 1883

client.connect(broker, port)


print("connected to broker")
client.loop_start() 

client.subscribe("/testmqtt/pushimage1")   

client.on_message = on_message


time.sleep(1000)
client.loop_forever()
return req

requirements.txt file
.......................................................
paho-mqtt
pillow==7.0.0

In mqttsubscribeimage function logs
..................................................................................
I can see only --> POST / - 200 OK - ContentLength: 50223

Your Environment

Running inside Minikube