Psycopg3 ile Uzun Süre Çalışan PostgreSQL Bildirim Dinleyicilerinde Kararlılığın Sağlanması

Uzun Süre Çalışan PostgreSQL Dinleyicilerinde Güvenilir Bildirimlerin Sağlanması

Uzun süredir devam eden veritabanı bağlantılarını yönetmek için Python ve psycopg3 kullanan arka uç uygulaması

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()

Alternatif Yaklaşım: Gelişmiş Yanıt Verme Hızı için Eşzamansız psycopg3 Kullanımı

Python'un asyncio ve psycopg3'ünü kullanarak eşzamansız uygulama

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())

Sağlamlık için Birim Testi

Unittest kullanarak arka uç mantığı için Python birim testleri

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()

PostgreSQL Bildirim Dinleyicilerini Yönetme Hakkında SSS

1. Amacı nedir? conn.notifies() psycopg3'te mi?
2. conn.notifies() PostgreSQL sunucusu tarafından gönderilen bildirimleri almak için kullanılır ve uygulamalarda gerçek zamanlı olay yönetimine olanak tanır.
3. Olabilmek LISTEN komutlar yeniden bağlanma sırasında mesajları kaybediyor mu?
4. Hayır, PostgreSQL bildirimleri arabelleğe alır, böylece yeniden bağlanma sırasında mesajlar kaybolmaz. Ancak, uygun şekilde işlenmesi notifies Kesintisiz işlem sağlamak için jeneratör gereklidir.
5. Neden kullanmalıyım? autocommit=True?
6. Ayar autocommit=True bağlantının aşağıdaki gibi komutları hemen uygulamasına olanak tanır LISTEN Açık bir taahhüt beklemeden yanıt verme hızını artırın.
7. Uzun süren bir çalışma sırasında sağlık kontrollerini nasıl yapabilirim? notifies işlem?
8. Gibi hafif sorguları periyodik olarak yürütebilirsiniz. SELECT 1 Bağlantının duyarlı kalmasını sağlamak için.
9. Veritabanı bağlantılarını temizlemeye yönelik en iyi uygulamalar nelerdir?
10. Bir kullanarak with bildirimi veya Python'un içerik yöneticisi, kaynak sızıntılarını önleyerek bağlantının düzgün bir şekilde kapatılmasını sağlar.
11. Zaman aşımı istisnalarını nasıl ele alabilirim? conn.notifies()?
12. Dürüm conn.notifies() zaman aşımı istisnalarını yakalamak ve bunları günlüğe kaydetme veya yeniden deneme gibi incelikli bir şekilde ele almak için bir try-hariç bloğunda.
13. psycopg3 bildirimler için eşzamansız işlemleri destekliyor mu?
14. Evet, psycopg3 asenkron bir API sunuyor. AsyncConnectionEngellenmeyen, ölçeklenebilir uygulamalar için idealdir.
15. Kapatmazsam ne olur notifies jeneratör?
16. Oluşturucunun kapatılmaması, özellikle uzun süren işlemlerde bellek sızıntılarına veya kaynakların askıda kalmasına neden olabilir.
17. Bir süre boyunca bildirimler kaçırılabilir mi? pg_sleep() operasyon mu?
18. Evet, uyku süresi sırasında oluşturulan bildirimler arabelleğe alınmadığı takdirde gözden kaçabilir; bu nedenle, LISTEN komutlar çok önemli.
19. Aynı bağlantıyı birden fazla bildirim için yeniden kullanmak güvenli midir?
20. Evet, durum kontrolleri ve yeniden bağlantılar uygun şekilde yönetildiği sürece aynı bağlantının yeniden kullanılması verimli ve kaynak dostudur.
21. Bildirim sistemimin güvenilirliğini nasıl test edebilirim?
22. Gibi kütüphaneleri kullanarak birim testleri yazın unittest.mock canlı bir sunucuya güvenmeden bildirimleri ve veritabanı davranışını simüle etmek için.

Güvenilir Bildirim Dinlemenin Sağlanması

Uzun süren işlemlerde bağlantı sağlığının korunması, kesintisiz işlemler için çok önemlidir. psycopg3'ün araçlarıyla conn.notify()geliştiriciler sağlam bildirim sistemleri uygulayabilir. Düzenli durum kontrolleri yanıt vermeyen bağlantıların önlenmesine yardımcı olur. Örnekler arasında kesintileri önlemek amacıyla canlı güncellemeler için envanter sistemlerinin izlenmesi yer alır.

Bildirim oluşturucunun kapatılması ve yeniden açılması, hafif SQL komutlarıyla birlikte hem performans hem de güvenilirlik sağlar. Bu teknikler, lojistik güncellemelerden finansal uyarılara kadar çeşitli kullanım durumları için geçerlidir. Bu tür stratejiler, kritik uygulamaların aksama sürelerine karşı korunmasına yardımcı olarak kusursuz bir kullanıcı deneyimi sağlar. ⚡