- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
我正在使用 RPI、VPS 和套接字 io。我想创建一个网站,用户可以在其中单击一个按钮并从 pi 获取图片。我用 python 编写了服务器和客户端应用程序。服务器使用socketio + flask
服务器.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[client]。
可能导致错误的原因是什么?解决方法是什么?谢谢你,祝你有美好的一天!
最佳答案
根据 python-socketio 文档,https://python-socketio.readthedocs.io/en/latest/client.html#emitting-events :
为方便起见,还提供了 send() 方法。此方法接受数据元素作为其唯一参数,并使用它发出标准消息事件:
sio.send('一些数据')
因此,您可以更改:
sio.send({'image': encoded_image})
到:
sio.emit('message', {'image': encoded_image})
关于linux - python socket io client emit 得到了一个意外的关键字参数 'wait',我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55693243/
我只是偶然发现了一个似乎广为人知的compsci关键字“emit”。但是我找不到用通用计算机科学术语对其的任何明确定义,也找不到任何特定编程语言中的“emit()”函数或关键字的特定定义。 我在这里找
在 Qt 中,它们都是有效的,并且表现相同: emit someSignal(value); 对比 emit(someSignal(value)); 有什么区别吗? 最佳答案 Is there any
是否可以同步执行并在调用方法本身时返回结果。所以,我想在 $emit 完成后执行下一条语句。其如下: Parent component has method, doC
我是 socket.io 的新手,遇到了一些看起来很奇怪的事情。我实际上不知道 socket.emit 和 io.emit 之间的区别,但我在任何地方都找不到解释。 io.on('connection
有谁知道如何显式实现接口(interface)的属性 使用反射。发射? 最佳答案 有关 TypeBuilder.DefineMethodOverride 的信息,请参阅 MSDN 文档,其中包括使用
我有多个可观察对象进行网络调用,并且仅当所有可观察对象发出错误时,我才需要从组合器可观察对象发出错误。如果至少有一个可观察完成,则应传递结果。 我当前的流功能如下: Observable.fromIt
我想在这里实现的是当 IF 语句为 true 时 fightID 更改为其他值,因此它不会匹配它之前分配的值,因此我无法在战斗结束后立即通过控制台运行 win-fight 发出的消息。但是我现在得到的
当我们需要自定义组件在 VueTable2 中发出事件时,我们必须使用: this.$parent.$emit('myCustomEvent') // instead of this.$emit('m
This is my production webpack config .标题中的两个引号分别指的是 webpack2 和 webpack。两者都因类似的错误而挂起。 这是我触发构建的命令 设置 N
我正在尝试构建一个发布者,它会在其他 5 个发布者中的任何一个发布者发出 true 时发出 true。我已经设法构建了一个工作版本,但感觉非常恶心,使用 CombineLatest4 + Combin
我正在尝试创建用于教育目的的简单 .net 编译器。在解析、扫描和构建 AST 之后,我正在使用 Reflection.Emit.ILGenerator 生成 .net 程序集。 这是我的程序集生成示
以下 node.js 脚本不工作 var EventEmitter = require('events').EventEmitter; var util = require('util'); var
我使用的是Laravel 10,Livewire 2.x,我试图使用Livewire组件中的一个简单函数中的emit或emitTo事件来更新愿望列表计数。。WishlistCount控制器:。当我运行
我收到以下警告: [Vue warn]: Extraneous non-emits event listeners (addData) were passed to component but cou
我不明白 io.emit 和 io.sockets.emit 之间有什么区别。 有时它们的行为相同,但有时它们的行为不同。 最佳答案 socket.emit 仅将消息发送到发送者客户端 io.emit
我刚刚成功地使用 socket.io 连接到一个服务器脚本,所以我很高兴。我对我的脚本生成的奇怪行为不太满意:我在单击按钮时向服务器脚本发送一个发射,然后服务器测试脚本向控制台日志发回一条消息 6x。
这听起来可能有点模糊,但我仍在学习并试图理解它是如何工作的。 我开始使用“侧菜单”启动 ionic 项目,它已经设置了带有“应用程序”抽象状态/ View / Controller 的 urlrout
我遵循了一些 Nodejs 教程并完成了一个简单的 REST Web 服务。此 Web 服务监听/api/accounts 中的电子邮件和密码,然后继续在 Cassandra 集群中进行查找。我使用
我正在尝试建立一种模式,在这种模式下,我的产生某些对象的可观察对象被转换为领域事件,例如围绕可观察对象产生的 Started、Success、Error,如果这有意义的话 public Observa
这个问题已经有答案了: How can I let the javascript catch a signal from node and prompt a window right after th
我是一名优秀的程序员,十分优秀!