Publishing OpenCV VideoCapture to NATS server about nats.py HOT 2 CLOSED

import cv2
import asyncio
from nats.aio.client import Client as NATS
import base64

async def run(loop):
    nc = NATS()
    await nc.connect(loop=loop)
    cap = cv2.VideoCapture(0)
    while True:
        frame = cap.read()[1]
        frame = cv2.resize(frame, dsize=(640,360))
        cv2.imwrite('before.png',frame)
        frame_base64 = base64.b64encode(frame)
        await nc.publish('foo', frame_base64)

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(run(loop))
    loop.run_forever()

import asyncio
from nats.aio.client import Client as NATS
import base64
import numpy as np
import cv2

async def run(loop):
    nc = NATS()
    await nc.connect(loop=loop)

    async def receiver(msg):
        data = msg.data.decode()
        frame_encoded = base64.b64decode(data)
        frame_encoded = np.frombuffer(frame_encoded, dtype=np.uint8)
        frame_encoded =frame_encoded.reshape(360,640,3)
        await cv2.imwrite('after.png',frame_encoded)

    await nc.subscribe("foo", cb=receiver)

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(run(loop))
    loop.run_forever()