送信側
import websocket
from picamera import camera
import io
class WebSocketClient(object):
def __init__(self, url, io_loop=None, extra_headers=None):
self.ws = websocket.WebSocketApp(url)
self.ws.on_open = self.on_open
self.state = True
self.picamera = camera.PiCamera()
self.picamera.resolution = (920,690) # 4:3
self.picamera.rotation = 270
def on_open(self):
self.state = True
print("open")
while(self.state):
stream = io.BytesIO()
for pixels in Picamera.capture_continuous(stream, "png"):
stream.seek(0)
data = stream.read()
print(type(data))
self.ws.send(data)
if __name__ == "__main__":
websocket.enableTrace(False)
ws_client = WebSocketClient("ws://SERVER")
ws_client.ws.run_forever()
受信側
from websocket_server import WebsocketServer
import threading
import json
import sys
import requests
import urllib
import traceback
from PIL import Image, ImageOps
from io import BytesIO
import io
class message:
def __init__(self, Type, data):
self.type = str(Type)
self.data = str(data)
def to_json(self):
return json.dumps(self.__dict__, ensure_ascii=False, indent=4)
def new_client(client, server):
print("new")
def message_received(client, server, Message):
try:
if(len(Message) > 100):
Message = Message.encode('UTF-8')
img_from_str = Image.open(Message)
img_from_str.save('test.png')
except:
traceback.print_exc()
# Main
if __name__ == "__main__":
server = WebsocketServer(port=12345, host='SERVER')
server.set_fn_new_client(new_client)
server.set_fn_message_received(message_received)
print("start")
server.run_forever()
としているのですが、PILのImage.open()を使ったところでエラーが出ます
画像データをpython3同士 / websocketにて送受信するサンプルが見つからず、組み合わせて書いているのですが
エンコード/デコードあたりがあまり自信がありません。
ご助言いただけると幸いです。