Hi! I would like to use SocketIO with a redis sentinel cluster. Unfo

This is how you do it: <div class="highlight highlight-source-python notranslate p

Hi <a class="user-mention notranslate" data-hovercard-type="user" data-hovercard-url="

Add support for redis sentinel cluster about flask-socketio HOT 2 CLOSED

wkedz commented on June 14, 2024

Add support for redis sentinel cluster

from flask-socketio.

Comments (2)

miguelgrinberg commented on June 14, 2024

This is how you do it:

mgr = ManagerClass("your", "arguments", "here")
socketio = SocketIO(client_manager=mgr)

All you need to do is pick a manager class that does what you need. I assume the RedisManager or KombuManager classes are what makes more sense to adapt it to work with a cluster, but I'm not sure if you can make this work just by adding extra arguments. Worst case you need to create a custom class that inherits from these and makes the necessary changes to work with a cluster.

from flask-socketio.

wkedz commented on June 14, 2024

Hi @miguelgrinberg

I pass the manager through client_manager and it works as it should.

Code:

app.logger.info(f"Connecting SocketIO to redis at {REDIS_HOST}")
url = REDIS_HOST # self.server_options.get('message_queue', None)
channel = "flask-socketio" # self.server_options.pop('channel', 'flask-socketio')
connection_options={"transport_options" : {"master_name":"mymaster"}}
write_only = False # app is None
client_manager = socketio.KombuManager(url=url, channel=channel, write_only=write_only, connection_options=connection_options)
sio = SocketIO(app, client_manager=client_manager, logger=True, engineio_logger=True)

Logs:

[2023-04-26 11:01:25,031] INFO in server: Connecting SocketIO to redis at sentinel://0.0.0.0:26379
Server initialized for eventlet.
h2j59VBXCfZbUIPRAAAA: Sending packet OPEN data {'sid': 'h2j59VBXCfZbUIPRAAAA', 'upgrades': ['websocket'], 'pingTimeout': 20000, 'pingInterval': 25000}
kombu backend initialized.
h2j59VBXCfZbUIPRAAAA: Received packet MESSAGE data 0{}
h2j59VBXCfZbUIPRAAAA: Sending packet MESSAGE data 0{"sid":"cI-uIDemeBQ6rEnlAAAB"}
pubsub message: emit
h2j59VBXCfZbUIPRAAAA: Sending packet MESSAGE data 2["my event",{"data":1}]
pubsub message: emit
h2j59VBXCfZbUIPRAAAA: Sending packet MESSAGE data 2["my event",{"data":2}]

Thanks for your help!

Closing, because there is no need to pass additional args to SocketIO.

from flask-socketio.

Recommend Projects