Ho un gran numero di righe in un database ciascuna contenente un token specifico dell'utente. Per ogni token ho bisogno di mantenere una connessione websocket aperta. Per ridimensionare questo mi piacerebbe eseguire più istanze del lavoratore. Quando viene aggiunto un nuovo token, un lavoratore disponibile dovrebbe aprire una connessione websocket per esso.
Il mio pensiero iniziale è stato periodicamente, vorrei verificare quante istanze del lavoratore sono in esecuzione e quale sono, quindi vorrei sapere quali token gestire.
Ad esempio, se sono un lavoratore di 18 su 35 e ci sono 22000 token, sono responsabile per i token 11,314 - 11,942 (22000/35 * 18 a 22000/35 * 19 - 1).
Non sono sicuro che si tratti di un ottimo approccio al problema. L'altra idea che avevo era di usare i blocchi di consulenza postgres in qualche modo per distribuire il lavoro.
Come sidenote sto cercando di capire il modo migliore per determinare il lavoratore m di n è. (Lo sto utilizzando su AWS usando ECS).