Ho una coda produttore / lavoratore (1 produttore, molti lavoratori).
Attualmente utilizzo Redis, ma non mi interessa passare a RabbitMQ o altro.
Il lavoratore prende un'attività dalla coda, esegue un lavoro di lunga durata e conferma che è finita.
Ora ho un nuovo tipo di lavoratore che consente l'elaborazione in coda più economica, ma potrebbe non essere sempre disponibile o potrebbero non essercene molti (istanza Spot AWS)
Devo fornire compiti dalla coda solo al nuovo tipo di lavoratore, ma se l'attività non riesce a elaborare dopo un po 'di tempo (cioè 30 secondi), dovrebbe invece essere fornita ad altri lavoratori per soddisfare lo SLA.
Come dovrei implementarlo?
In breve, ho bisogno di consegnare un messaggio a una coda, e rimane lì per più di 10 secondi, spostarlo in un'altra coda.