сокет Python IO клиент Emit получил неожиданный аргумент ключевого слова «ждать» - PullRequest
1 голос
/ 15 апреля 2019

Я использую RPI, VPS и сокет io.Я хочу создать сайт, на котором пользователь может щелкнуть по кнопке и получить картинку с пи.Я написал сервер и клиентские приложения на python.сервер использует socketio + flask

server.py

from flask import Flask, request, render_template
from flask_socketio import SocketIO, rooms, join_room, leave_room

app = Flask(__name__, static_url_path='/static')
app.config['SECRET_KEY'] = 'secret!'
sio = SocketIO(app)

@app.route('/')
def index():
    """Serve the client-side application."""
    with open('index.html') as f:
        return f.read()
    # return app.send_static_file('index.html')

@sio.on('connect')
def connect():
    print('Connected:')

@sio.on('join')
def on_join(room):
    join_room(room)
    print(request.sid + ' joined room ' + room )

@sio.on('leave')
def on_leave(room):
    leave_room(room)
    print(request.sid + ' left room ' + room )

@sio.on('message')
def handle_json(message):
    # print('Received json: ')
    # print(message)
    room = rooms(request.sid)[0]
    print('Forwarding to room:', room)
    sio.send(message, room=room, skip_sid=request.sid, json=True)


if __name__ == '__main__':
    sio.run(app, host= "142.11.210.25", port = 80)

rpi_client.py

import io
import time

import picamera
import socketio
import base64

sio = socketio.Client()

# Specify the room
room = 'cam_1'
socket_url = 'http://142.11.210.25:80/'

def capture_b64_image():
    # Create an in-memory stream
    image_stream = io.BytesIO()

    # Capture image
    with picamera.PiCamera() as camera:
        # Camera warm-up time
        time.sleep(2)
        camera.capture(image_stream, 'jpeg')

    # Encode the image
    image_bytes = image_stream.getvalue()   
    return base64.b64encode(image_bytes).decode()


@sio.on('connect')
def on_connect():
    print('Connection established')
    sio.emit('join', room)

@sio.on('json')
def on_message(data):
    print('Received message:', data)

    encoded_image = capture_b64_image()

    print( len(encoded_image) )
    sio.send({'image': encoded_image})


@sio.on('disconnect')
def on_disconnect():
    print('Disconnected from server')

sio.connect(socket_url)
sio.wait()

index.html

<!DOCTYPE html>
<html>
    <head>
        <title>SocketIO Demo</title>
    </head>

    <body>
        <img id="image-preview" src="" />

        <button id='cam_click'>Take photo</button>

        <script
            src="http://code.jquery.com/jquery-3.3.1.js"
            integrity="sha256-2Kok7MbOyxpgUVvAk/HJ2jigOSYS2auK4Pfzbm7uH60="
            crossorigin="anonymous"></script>
        <script src="/static/js/socket.io.js"></script>
        <script>
            var socket = io('/');
            var room = 'cam_1';

            function bytes2ascii(bytes) {
                var str = '';
                for(var i = 0; i < bytes.length; i++) {
                    str += String.fromCharCode(bytes[i]);
                }

                return str;
            }

            socket.on('connect', function() {
                console.log(11);
                socket.emit('join', room);
            });

            socket.on('json', function (data) {
                console.log('Received:');
                console.log(data);
                // $('#cam_content').html(data.image);

                //var encoded_image = bytes2ascii(new Uint8Array(data.image) );
                var encoded_image = data.image

                $('#image-preview').attr('src', `data:image/png;base64,${encoded_image}`);

            });

            $(document).ready(function() {
                console.log('Ready...');
                $('#cam_click').click(function() {
                    socket.send('image');
                });
            });
        </script>
    </body>
</html>

, когда язапустить сервер и клиент rpi, я установил соединение, и когда я нажимаю на кнопку, чтобы сделать фотографию в index.html, сервер переходит в комнату room1, и я получаю это на клиенте rpi, и он берет рис, но затемон вылетает при отправке картинки и дает мне TypeError: emit () получил неожиданный аргумент ключевого слова 'wait'

вот ошибка, которую я получаю (клиент rpi), когда запускаю коды.

Connection established
Received message: image
996008
Exception in thread Thread-5:
Traceback (most recent call last):
  File "/usr/lib/python3.5/threading.py", line 914, in _bootstrap_inner
    self.run()
  File "/usr/lib/python3.5/threading.py", line 862, in run
    self._target(*self._args, **self._kwargs)
  File "/usr/local/lib/python3.5/dist-packages/socketio/client.py", line 514, in _handle_eio_message
    self._handle_event(pkt.namespace, pkt.id, pkt.data)
  File "/usr/local/lib/python3.5/dist-packages/socketio/client.py", line 413, in _handle_event
    r = self._trigger_event(data[0], namespace, *data[1:])
  File "/usr/local/lib/python3.5/dist-packages/socketio/client.py", line 455, in _trigger_event
    return self.handlers[namespace][event](*args)
  File "rpi_client2.py", line 41, in on_message
    sio.send({'image': encoded_image})
  File "/usr/local/lib/python3.5/dist-packages/socketio/client.py", line 296, in send
    callback=callback, wait=wait, timeout=timeout)
TypeError: emit() got an unexpected keyword argument 'wait'

Я установил python-socketio [клиент] в соответствии с инструкциями.

Что может быть причиной ошибки и какой обходной путь?спасибо и хорошего дня!

1 Ответ

0 голосов
/ 24 апреля 2019

Согласно документу python-socketio, https://python -socketio.readthedocs.io / en / latest / client.html # emitting-events :

Для удобства отправьте() метод также предоставляется.Этот метод принимает элемент данных в качестве единственного аргумента и генерирует стандартное событие сообщения вместе с ним:

sio.send ('некоторые данные')

Следовательно, вы можете изменить:

sio.send ({'image': encoded_image})

to:

sio.emit ('message', {'image': encoded_image})

...