Awesome GitHub RepositoriesPostgreSQL Task Queues

River este o coadă de joburi tranzacțională și un scheduler de joburi distribuit pentru Go care utilizează PostgreSQL pentru persistență și gestionarea stării. Acesta funcționează ca un framework de task-uri reluabile, permițând ca munca de fundal de lungă durată să fie împărțită în pași persistenți care pot fi reluați de la ultimul checkpoint salvat după o eroare. Sistemul asigură o consistență strictă a datelor permițând ca task-urile de fundal să fie puse în coadă și finalizate în cadrul aceleiași tranzacții de bază de date ca și datele principale ale aplicației. Se distinge printr-un model de coordonator care utilizează alegerea liderului pentru a gestiona task-urile periodice și întârziate într-un cluster de noduri worker. Platforma acoperă un set larg de capabilități, inclusiv procesarea asincronă a task-urilor, configurarea politicii de reîncercare cu backoff exponențial și izolarea sarcinilor de lucru prin cozi numite. Oferă, de asemenea, instrumente pentru monitorizare printr-o interfață de gestionare web, telemetrie de execuție și un sistem middleware pentru injectarea preocupărilor transversale precum logarea. Migrările schemei bazei de date pot fi gestionate printr-o interfață în linie de comandă sau direct prin cod.

PGMQ este un sistem de coadă de mesaje ușor implementat ca o extensie PostgreSQL pentru gestionarea sarcinilor asincrone. Acesta funcționează ca un broker de mesaje bazat pe baza de date care utilizează PostgreSQL pentru stocare persistentă, operațiuni atomice și livrare bazată pe notificări. Sistemul oferă un model de coadă compatibil cu SQS, cu timeout-uri de vizibilitate și livrare întârziată. Suportă ordonarea strictă first-in-first-out prin chei de grup și regăsirea în loturi pentru a asigura procesarea secvențială a sarcinilor conexe. Proiectul acoperă un ciclu de viață complet al mesajului, inclusiv producția, consumul prin operațiuni pop atomice și gestionarea administrativă, cum ar fi curățarea cozii și controlul ciclului de viață. Include capabilități de rutare prin modele bazate pe subiecte și funcționalități de fiabilitate precum dead letter queueing, arhivarea mesajelor și logica de reîncercare. Sunt furnizate instrumente de monitorizare pentru a urmări metricile operaționale, cum ar fi lungimea cozii și throughput-ul.

Queue Classic este un framework de procesare în fundal pentru aplicațiile Ruby care gestionează sarcinile asincrone prin utilizarea tabelelor de baze de date relaționale pentru persistența job-urilor. Prin stocarea sarcinilor direct în baza de date, sistemul asigură că crearea job-ului rămâne cuplată cu tranzacțiile aplicației, garantând că sarcinile sunt puse în coadă doar atunci când modificările de date asociate sunt confirmate cu succes. Framework-ul coordonează procesele worker concurente prin mecanisme de blocare la nivel de bază de date, care previn execuția redundantă și permit procesarea sarcinilor distribuite fără a fi nevoie de un broker de mesaje extern. Worker-ii operează prin interogarea bazei de date pentru job-urile în așteptare, suportând atât execuția imediată, cât și programarea întârziată bazată pe timestamp-uri viitoare. Sistemul oferă un mecanism pentru descărcarea operațiunilor consumatoare de timp din firul principal al aplicației către procese worker independente. Suportă configurații de handler personalizate, permițând dezvoltatorilor să definească logică specifică pentru sarcinile în fundal, menținând în același timp consistența prin stocarea relațională subiacentă.