Stabilitātes nodrošināšana ilgstošajos PostgreSQL paziņojumu uztvērējos, izmantojot Psycopg3

Uzticamu paziņojumu nodrošināšana ilgstošajos PostgreSQL klausītājos

Aizmugursistēmas ieviešana, izmantojot Python un psycopg3, lai apstrādātu ilgstošus datu bāzes savienojumus

import psycopg
from psycopg import sql
import time
CONN_STR = "postgresql://user:password@localhost/dbname"
def listen_notifications():
    try:
        with psycopg.connect(CONN_STR, autocommit=True) as conn:
            listen_sql = sql.SQL("LISTEN {};").format(sql.Identifier("scheduler_test"))
            conn.execute(listen_sql)
            print("Listening for notifications...")
            gen = conn.notifies(timeout=5)
            for notification in gen:
                print("Received notification:", notification)
                perform_health_check(conn, listen_sql)
    except Exception as e:
        print("Error:", e)
def perform_health_check(conn, listen_sql):
    try:
        print("Performing health check...")
        conn.execute("SELECT 1")
        conn.execute(listen_sql)
    except Exception as e:
        print("Health check failed:", e)
if __name__ == "__main__":
    listen_notifications()

Alternatīva pieeja: asinhronā psycopg3 izmantošana uzlabotai reaģēšanai

Asinhronā ieviešana, izmantojot Python asyncio un psycopg3

import asyncio
from psycopg import AsyncConnection, sql
CONN_STR = "postgresql://user:password@localhost/dbname"
async def listen_notifications():
    try:
        async with AsyncConnection.connect(CONN_STR, autocommit=True) as conn:
            listen_sql = sql.SQL("LISTEN {};").format(sql.Identifier("scheduler_test"))
            await conn.execute(listen_sql)
            print("Listening for notifications...")
            gen = conn.notifies(timeout=5)
            async for notification in gen:
                print("Received notification:", notification)
                await perform_health_check(conn, listen_sql)
    except Exception as e:
        print("Error:", e)
async def perform_health_check(conn, listen_sql):
    try:
        print("Performing health check...")
        await conn.execute("SELECT 1")
        await conn.execute(listen_sql)
    except Exception as e:
        print("Health check failed:", e)
if __name__ == "__main__":
    asyncio.run(listen_notifications())

Vienības izturības pārbaude

Python vienības testē aizmugursistēmas loģiku, izmantojot unittest

import unittest
from unittest.mock import patch, MagicMock
class TestNotificationListener(unittest.TestCase):
    @patch("psycopg.connect")
    def test_listen_notifications(self, mock_connect):
        mock_conn = MagicMock()
        mock_connect.return_value.__enter__.return_value = mock_conn
        mock_conn.notifies.return_value = iter(["test_notification"])
        listen_notifications()
        mock_conn.execute.assert_called_with("LISTEN scheduler_test;")
        mock_conn.notifies.assert_called_once()
if __name__ == "__main__":
    unittest.main()

Bieži uzdotie jautājumi par PostgreSQL paziņojumu uztvērēju pārvaldību

1. Kāds ir mērķis conn.notifies() programmā psycopg3?
2. conn.notifies() tiek izmantots, lai izgūtu PostgreSQL servera nosūtītos paziņojumus, nodrošinot reāllaika notikumu apstrādi lietojumprogrammās.
3. Var LISTEN komandas zaudē ziņojumus atkārtotas savienojuma laikā?
4. Nē, PostgreSQL buferē paziņojumus, tāpēc ziņojumi netiek zaudēti atkārtotas savienojuma laikā. Tomēr pareiza rīcība ar notifies ģenerators ir nepieciešams, lai nodrošinātu netraucētu apstrādi.
5. Kāpēc man vajadzētu lietot autocommit=True?
6. Iestatījums autocommit=True ļauj savienojumam nekavējoties lietot tādas komandas kā LISTEN negaidot skaidru apņemšanos, uzlabojot atsaucību.
7. Kā es varu veikt veselības pārbaudes ilgstošas ​​​​skrējiena laikā notifies process?
8. Jūs varat periodiski izpildīt vieglus vaicājumus, piemēram SELECT 1 lai nodrošinātu, ka savienojums joprojām reaģē.
9. Kāda ir labākā prakse datu bāzes savienojumu tīrīšanai?
10. Izmantojot a with paziņojums vai Python konteksta pārvaldnieks nodrošina, ka savienojums ir pareizi aizvērts, izvairoties no resursu noplūdes.
11. Kā rīkoties ar taimauta izņēmumiem conn.notifies()?
12. Aptinums conn.notifies() izmēģināšanas blokā, lai uztvertu noildzes izņēmumus un apstrādātu tos graciozi, piemēram, reģistrējot vai mēģinot atkārtoti.
13. Vai psycopg3 atbalsta paziņojumu asinhronās darbības?
14. Jā, psycopg3 piedāvā asinhronu API, izmantojot AsyncConnection, kas ir ideāli piemērots nebloķējošām, mērogojamām lietojumprogrammām.
15. Kas notiks, ja es neaizveršu notifies ģenerators?
16. Ja ģenerators netiek aizvērts, var rasties atmiņas noplūde vai resursi, jo īpaši ilgstošas ​​darbības procesos.
17. Vai paziņojumus var palaist garām a pg_sleep() operācija?
18. Jā, miega perioda laikā ģenerētie paziņojumi var tikt palaisti garām, ja tie netiks buferēti, tāpēc pareizi rīkojieties LISTEN komandām ir izšķiroša nozīme.
19. Vai ir droši atkārtoti izmantot vienu un to pašu savienojumu vairākiem paziņojumiem?
20. Jā, ja vien tiek pārvaldītas veselības pārbaudes un pareizi atjaunoti savienojumi, tā paša savienojuma atkārtota izmantošana ir efektīva un resursiem draudzīga.
21. Kā es varu pārbaudīt savas paziņojumu sistēmas uzticamību?
22. Rakstiet vienību testus, izmantojot tādas bibliotēkas kā unittest.mock lai simulētu paziņojumus un datu bāzes uzvedību, nepaļaujoties uz reāllaika serveri.

Uzticamas paziņojumu klausīšanās nodrošināšana

Savienojuma veselības uzturēšana ilgstošiem procesiem ir būtiska nepārtrauktai darbībai. Ar psycopg3 rīkiem, piemēram conn.notifyes(), izstrādātāji var ieviest spēcīgas paziņojumu sistēmas. Regulāras veselības pārbaudes palīdz izvairīties no nereaģējošiem savienojumiem. Kā piemērus var minēt inventarizācijas sistēmu pārraudzību, lai nodrošinātu tiešraides atjauninājumus, lai novērstu pārtraukumus.

Paziņojumu ģeneratora aizvēršana un atkārtota atvēršana kopā ar vieglajām SQL komandām nodrošina gan veiktspēju, gan uzticamību. Šīs metodes attiecas uz dažādiem lietošanas gadījumiem, sākot no loģistikas atjauninājumiem līdz finanšu brīdinājumiem. Šādas stratēģijas palīdz aizsargāt kritiskās lietojumprogrammas pret dīkstāvi, nodrošinot nevainojamu lietotāja pieredzi. ⚡