Connecting Multiple Raspberry Pi Clients to a Raspberry Pi Server with Socket.IO

client1.py

# Running on Raspberry Pi 1
import socketio

sio = socketio.Client()

def send_sensor_readings():
    while True:
        sio.emit('my_message', {'temp':75})
        sio.sleep(5)

@sio.event
def connect():
    print('connection established')
    sio.start_background_task(send_sensor_readings)

@sio.event
def disconnect():
    print('disconnected from server')

sio.connect('http://localhost:5000', headers={'device_id':'client1'})

client2.py

# Run this code on Raspberry Pi 2
import socketio

sio = socketio.Client()

def send_sensor_readings():
    while True:
        sio.emit('my_message', {'humidity':40})
        sio.sleep(5)

@sio.event
def connect():
    print('connection established')
    sio.start_background_task(send_sensor_readings)

@sio.event
def disconnect():
    print('disconnected from server')

sio.connect('http://localhost:5000', headers={'device_id':'client2'})

client3.py

# Raspberry Pi 3
import socketio

sio = socketio.Client()

def send_sensor_readings():
    while True:
        sio.emit('my_message', {'temp':80})
        sio.sleep(5)

@sio.event
def connect():
    print('connection established')
    sio.start_background_task(send_sensor_readings)

@sio.event
def disconnect():
    print('disconnected from server')

sio.connect('http://localhost:5000')

myserver.py

# Running on the Raspberry Pi server

import eventlet
import socketio

sio = socketio.Server()
app = socketio.WSGIApp(sio)

def get_device_id(environ):
    return environ.get('HTTP_DEVICE_ID', None)

@sio.event
def connect(sid, environ):
    device_id = get_device_id(environ) or sid
    sio.save_session(sid, {'device_id': device_id})
    print('{} is connected'.format(device_id))

@sio.event
def my_message(sid, data):
    session = sio.get_session(sid)
    print('Received data from {}: {}'.format(session['device_id'], data))

@sio.event
def disconnect(sid):
    print('disconnect ', sid)

if __name__ == '__main__':
    eventlet.wsgi.server(eventlet.listen(('', 5000)), app, log_output=False)