Problem
So I need to make a python application that can sit on a machine, open up a websocket pipe to a server running flask-socketio, then pipe data across to the server. The data will be json data, for now I am testing with a string.
I am having an issue using the 'websockets' library in python to connect to the 'flask-socketio' backend that I am making.
Code
Server
from flask import Flask, render_template, request, url_for,
copy_current_request_context
from flask_socketio import SocketIO, emit
import logging
logging.basicConfig()
app = Flask(__name__)
app.config['SECRET_KEY'] = 'secret!'
app.config['DEBUG'] = True
socketio = SocketIO(app)
@socketio.on('connect', namespace='/')
def connect():
print('Client connected')
@socketio.on('disconnect', namespace='/')
def disconnect():
print('Client disconnected')
if __name__ == '__main__':
socketio.run(app, debug=True)
Client 1 - websockets library
import asyncio
import websockets
async def hello():
async with websockets.connect(
'ws://127.0.0.1:5000') as websocket:
name = 'joe' # input("What's your name? ")
await websocket.send('message', name)
print(f"> {name}")
greeting = await websocket.recv()
print(f"< {greeting}")
asyncio.get_event_loop().run_until_complete(hello())
print("end")
Use output
When I use client 1 I get this as output on the client process:
Traceback (most recent call last):
File "C:/project_files/aWebUAS/micro-services/New-Capabilities-Investigation/web_socket_client.py", line 15, in <module>
asyncio.get_event_loop().run_until_complete(hello())
File "C:\Program Files\Anaconda3\lib\asyncio\base_events.py", line 466, in run_until_complete
return future.result()
File "C:/project_files/aWebUAS/micro-services/New-Capabilities-Investigation/web_socket_client.py", line 6, in hello
'ws://127.0.0.1:5000') as websocket:
File "C:\Program Files\Anaconda3\lib\site-packages\websockets\py35\client.py", line 2, in __aenter__
return await self
File "C:\Program Files\Anaconda3\lib\site-packages\websockets\py35\client.py", line 20, in __await_impl__
extra_headers=protocol.extra_headers,
File "C:\Program Files\Anaconda3\lib\site-packages\websockets\client.py", line 286, in handshake
raise InvalidStatusCode(status_code)
websockets.exceptions.InvalidStatusCode: Status code not 101: 404
and on the flask process I see:
127.0.0.1 - - [2019-04-05 09:17:13] "GET / HTTP/1.1" 404 342 0.000999
Client 2 - websocket-client library
import websocket
ws = websocket.WebSocket()
ws.connect("ws://127.0.0.1:5000")
ws.send("Hello, World")
Use output
On the client 2 process I get this as output:
Traceback (most recent call last):
File "C:/project_files/aWebUAS/micro-services/New-Capabilities-Investigation/web_socket_client_2.py", line 3, in <module>
ws.connect("ws://127.0.0.1:5000")
File "C:\Program Files\Anaconda3\lib\site-packages\websocket\_core.py", line 226, in connect
self.handshake_response = handshake(self.sock, *addrs, **options)
File "C:\Program Files\Anaconda3\lib\site-packages\websocket\_handshake.py", line 79, in handshake
status, resp = _get_resp_headers(sock)
File "C:\Program Files\Anaconda3\lib\site-packages\websocket\_handshake.py", line 160, in _get_resp_headers
raise WebSocketBadStatusException("Handshake status %d %s", status, status_message, resp_headers)
websocket._exceptions.WebSocketBadStatusException: Handshake status 404 NOT FOUND
and the flask process shows this:
127.0.0.1 - - [2019-04-05 09:11:57] "GET / HTTP/1.1" 404 342 0.001000
Conclusion
Some reading around tells me I am not hitting my socketio handler within flask properly, but I am unsure how to target that.
Any help is much appreciated. My goal is to have a python script talking to a flask socketio server. I am not married to any part of this but would prefer to stick to flask for the server.
TIA - Ian
