Sfondo
Ho due processi separati, WriteIt() e ReadIt() . Uno crea i record e l'altro elabora i record in un cluster DB.
Una volta che WriteIt() crea un record, accoda un ReadIt() task per elaborare lo stesso record.
Per illustrare:
Sfortunatamente, la scrittura e la replica del database richiedono una quantità di tempo inaffidabile, quindi ReadIt() deve continuare a controllare la presenza del record aggiornato, il che sembra abbastanza inefficiente.
Domanda
Questo deve essere un modello comune per i sistemi distribuiti. Quindi le mie domande sono:
-
Esiste un termine generale (o termini) per questo modello, in modo che io possa leggere come risolverlo? Sfortunatamente non so nemmeno quale sia la terminologia giusta, quindi ho fatto un po 'di tempo a fare ricerche su Google / SO / Programmers.SE.
-
(per crediti extra) Esiste un approccio comune specifico per risolvere questo problema con SQLAlchemy / MySQL e Celery?
Riconosco che il n. 2 è piuttosto specifico, quindi sarei felice solo con il n. 1 dal momento che ho solo bisogno di essere indirizzato nella giusta direzione per ricercare il modello.