Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import paho.mqtt.client as mqtt
- import time
- import cv2
- import numpy
- import json
- MQTT_SERVER = "iot.eclipse.org"
- MQTT_PATH = "test_channel"
- mqttc = mqtt.Client()
- mqttc.connect(MQTT_SERVER, 1883, 60)
- cap = cv2.VideoCapture(0)
- while True:
- ret, frame = cap.read()
- frame_list = frame.tolist()
- frame_json = json.dumps(frame_list)
- MQTT_MESSAGE = frame_json
- mqttc.publish(MQTT_PATH, MQTT_MESSAGE)
- time.sleep(1)
- import paho.mqtt.client as mqtt
- import numpy as np
- import json
- import PIL
- MQTT_SERVER = "iot.eclipse.org"
- MQTT_PATH = "test_channel"
- def on_connect(client, userdata, flags, rc):
- print("connected with result code " + str(rc))
- client.subscribe(MQTT_PATH)
- def on_message(client, userdata, msg):
- data = json.loads(msg.payload)
- array = np.array(data)
- img = PIL.Image.fromarray(array)
- cv2.imshow('image', img)
- cv2.waitKey()
- client = mqtt.Client()
- client.on_connect = on_connect
- client.on_message = on_message
- client.connect(MQTT_SERVER, 1883, 60)
- client.loop_forever()
Add Comment
Please, Sign In to add comment