Я создаю приложение для веб-сервера с aiohttp и python. Для обмена данными я использую реализацию socketio python. Для получения данных из моего интерфейса в мой скрипт на Python все работает как положено. Теперь я хочу отправить некоторые данные из моего скрипта Python для отображения в браузере. По этой причине я хочу реализовать функцию, которая излучает данные.
Когда я пытаюсь вызвать socket_io.emit('data',"test") напрямую, я получаю предупреждение во время выполнения:
RuntimeWarning: coroutine 'AsyncServer.emit 'никогда не ожидался> my_server.socket_io.emit (' data ', "test") RuntimeWarning: включить tracemalloc для получения трассировки выделения объекта
Я уже провел некоторые исследования, и это нормальноя думаю.
Когда я создаю определение асинхронной функции следующим образом:
async def sendData(dataOut):
await socket_io.emit('dataOut', dataOut)
сообщение не отправляется
Это мой тестовый код Python:
from aiohttp import web
import socketio
socket_io = socketio.AsyncServer(async_mode='aiohttp')
app = web.Application()
socket_io.attach(app)
app.router.add_static('/', path=str('public/'))
configData = "testConfig"
dataOut ="testOut"
dataBack ="testBack"
async def index(request):
with open('public/index.html') as f:
return web.Response(text=f.read(), content_type='text/html')
app.router.add_get('/', index)
@socket_io.on('connect')
async def connect_handler(sid, environ):
print("new connection") # works as expected
await socket_io.emit('initial_config', configData) # works as expected
@socket_io.on("dataIn")
async def dataInHandler(sid, data):
print("new data") # works as expected
await socket_io.emit('dataBack', dataBack) # works as expected
async def sendData(dataOut):
await socket_io.emit('dataOut', dataOut)
web.run_app(app, host='XXX.XXX.XXX.XXX', port='XXXX')
sendData(dataOut) #is not doing anything
И используемый "публичный" HTML-файл:
<!-- index.html -->
<!DOCTYPE html>
<html lang="en">
<head>
<title>socketio Test</title>
</head>
<body>
<h1>socketio Test</h1>
<input type="checkbox" value="0" onClick="emit(id)" id="IN1"></input>
<script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/2.2.0/socket.io.js"></script>
<script>
const socket = io("http://XXX.XXX.XXX.XXX:XXXX");
function emit(id){
channel_obj = eval(id)
console.log(id, typeof(id), channel_obj.value, typeof(channel_obj.value))
if (channel_obj.value == 1){
channel_obj.value = 0
}
else{
channel_obj.value = 1
}
socket.emit("dataIn", id+":"+channel_obj.value);
}
socket.on("initial_config", function(data) {
console.log(data);
});
socket.on("dataBack", function(data) {
console.log(data);
});
socket.on("dataOut", function(data) {
console.log(data);
});
</script>
</body>
</html>
Как создать функцию, которая выдает данные при вызове?
РЕДАКТИРОВАТЬ:
Новый скрипт Python для вызова функции emit из другого потока:
from aiohttp import web
import socketio, threading, time
configData = "testConfig"
dataOut ="testOut"
dataBack ="testBack"
data_flag = 0
connection_flag = 0
print("setup web-server")
socket_io = socketio.AsyncServer(async_mode='aiohttp')
app = web.Application()
socket_io.attach(app)
app.router.add_static('/', path=str('public/'))
async def index(request):
with open('public/index.html') as f:
return web.Response(text=f.read(), content_type='text/html')
app.router.add_get('/', index)
@socket_io.on('connect')
async def connect_handler(sid, environ):
global connection_flag
print("new connection") # works as expected
connection_flag = 1
await socket_io.emit('initial_config', configData) # works as expected
@socket_io.on("dataIn")
async def dataInHandler(sid, data):
print("new data") # works as expected
data_flag = 1
await socket_io.emit('dataBack', dataBack) # works as expected
async def sendData(dataOut):
await socket_io.emit('dataOut', dataOut)
def main():
global connection_flag
try:
print("in main loop")
time.sleep(1)
print("wait till a client connects")
while connection_flag == 0:
pass
print("wait 5 seconds")
time.sleep(5)
i = 0
while True:
print("now emitting: ", i)
sendData(i)
i += 1
time.sleep(1)
finally:
thread.join()
print("finished, exiting now")
thread = threading.Thread(target=main, args=())
thread.daemon=True
thread.start()
print("starting web-server")
web.run_app(app, host='192.168.132.210', port='5000')
Шаги для воспроизведения:
- Запустите сервер, без подключения клиента:
setup web-server
in main loop
starting web-server
======== Running on http://192.168.132.210:5000 ========
(Press CTRL+C to quit)
wait till a client connects
Подключение через браузер
new connection
wait 5 seconds
now emitting: 0
aiohttp_thread.py:53: RuntimeWarning: coroutine 'sendData' was never awaited
sendData(i)
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
now emitting: 1
now emitting: 2
now emitting: 3
now emitting: 4
now emitting: 5