Psycopg3 உடன் நீண்ட காலமாக இயங்கும் PostgreSQL அறிவிப்பு கேட்பவர்களில் நிலைத்தன்மையை உறுதி செய்தல்

நீண்ட காலமாக இயங்கும் PostgreSQL கேட்பவர்களில் நம்பகமான அறிவிப்புகளை உறுதி செய்தல்

நீண்ட கால தரவுத்தள இணைப்புகளைக் கையாள பைதான் மற்றும் சைகோப்ஜி 3 ஐப் பயன்படுத்தி பின்தளத்தில் செயல்படுத்தல்

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

மாற்று அணுகுமுறை: மேம்பட்ட வினைத்திறனுக்காக ஒத்திசைவற்ற psycopg3 ஐப் பயன்படுத்துதல்

பைத்தானின் அசின்சியோ மற்றும் சைகோப்ஜி 3 ஐப் பயன்படுத்தி ஒத்திசைவற்ற செயலாக்கம்

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

வலிமைக்கான அலகு சோதனை

பைதான் யூனிட் யூனிட்டெஸ்டைப் பயன்படுத்தி பின்தள தர்க்கத்திற்கான சோதனைகள்

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 அறிவிப்பு கேட்பவர்களை நிர்வகிப்பதற்கான அடிக்கடி கேட்கப்படும் கேள்விகள்

1. நோக்கம் என்ன conn.notifies() psycopg3 இல்?
2. conn.notifies() PostgreSQL சேவையகத்தால் அனுப்பப்பட்ட அறிவிப்புகளை மீட்டெடுக்கப் பயன்படுகிறது, பயன்பாடுகளில் நிகழ்நேர நிகழ்வு கையாளுதலை செயல்படுத்துகிறது.
3. முடியும் LISTEN மீண்டும் இணைக்கும் போது கட்டளைகள் செய்திகளை இழக்குமா?
4. இல்லை, PostgreSQL அறிவிப்புகளை இடையகப்படுத்துகிறது, எனவே மீண்டும் இணைக்கும் போது செய்திகள் இழக்கப்படாது. இருப்பினும், சரியான கையாளுதல் notifies தடையற்ற செயலாக்கத்தை உறுதிப்படுத்த ஜெனரேட்டர் தேவை.
5. நான் ஏன் பயன்படுத்த வேண்டும் autocommit=True?
6. அமைத்தல் autocommit=True போன்ற கட்டளைகளை உடனடியாகப் பயன்படுத்த இணைப்பை அனுமதிக்கிறது LISTEN வெளிப்படையான உறுதிப்பாட்டிற்காக காத்திருக்காமல், பதிலளிப்பதை மேம்படுத்துகிறது.
7. நீண்ட கால இடைவெளியில் நான் எப்படி சுகாதார சோதனைகளை மேற்கொள்ள முடியும் notifies செயல்முறை?
8. போன்ற இலகுரக வினவல்களை நீங்கள் அவ்வப்போது இயக்கலாம் SELECT 1 இணைப்பு பதிலளிக்கக்கூடியதாக இருப்பதை உறுதிசெய்ய.
9. தரவுத்தள இணைப்புகளை சுத்தம் செய்வதற்கான சிறந்த நடைமுறைகள் யாவை?
10. ஒரு பயன்படுத்தி with அறிக்கை அல்லது பைத்தானின் சூழல் மேலாளர், ஆதார கசிவுகளைத் தவிர்த்து, இணைப்பு சரியாக மூடப்பட்டிருப்பதை உறுதிசெய்கிறது.
11. காலக்கெடு விதிவிலக்குகளை எவ்வாறு கையாள்வது conn.notifies()?
12. மடக்கு conn.notifies() காலாவதியான விதிவிலக்குகளைப் பிடிக்கவும், உள்நுழைவது அல்லது மீண்டும் முயற்சிப்பது போன்றவற்றை அழகாகக் கையாளவும் முயற்சி-தவிர தொகுதியில்.
13. psycopg3 அறிவிப்புகளுக்கான ஒத்திசைவற்ற செயல்பாடுகளை ஆதரிக்கிறதா?
14. ஆம், psycopg3 ஒரு ஒத்திசைவற்ற API ஐ வழங்குகிறது AsyncConnection, இது தடுக்காத, அளவிடக்கூடிய பயன்பாடுகளுக்கு ஏற்றது.
15. நான் மூடவில்லை என்றால் என்ன நடக்கும் notifies ஜெனரேட்டரா?
16. ஜெனரேட்டரை மூடத் தவறினால் நினைவக கசிவுகள் அல்லது தொங்கும் வளங்கள், குறிப்பாக நீண்ட கால செயல்முறைகளில் ஏற்படலாம்.
17. ஒரு போது அறிவிப்புகளைத் தவறவிட முடியுமா pg_sleep() அறுவை சிகிச்சை?
18. ஆம், உறங்கும் காலத்தின் போது உருவாக்கப்படும் அறிவிப்புகள் பஃபர் செய்யப்படாவிட்டால் தவறவிடப்படலாம், அதனால்தான் சரியாகக் கையாளுதல் LISTEN கட்டளைகள் முக்கியம்.
19. பல அறிவிப்புகளுக்கு ஒரே இணைப்பை மீண்டும் பயன்படுத்துவது பாதுகாப்பானதா?
20. ஆம், சுகாதாரச் சோதனைகள் மற்றும் முறையான மறு இணைப்புகள் நிர்வகிக்கப்படும் வரை, அதே இணைப்பை மீண்டும் பயன்படுத்துவது திறமையானது மற்றும் வளத்துக்கு ஏற்றது.
21. எனது அறிவிப்பு அமைப்பின் நம்பகத்தன்மையை நான் எப்படிச் சோதிப்பது?
22. போன்ற நூலகங்களைப் பயன்படுத்தி அலகு சோதனைகளை எழுதுங்கள் unittest.mock நேரடி சேவையகத்தை நம்பாமல் அறிவிப்புகள் மற்றும் தரவுத்தள நடத்தையை உருவகப்படுத்த.

நம்பகமான அறிவிப்பைக் கேட்பதை உறுதி செய்தல்

நீண்ட கால செயல்முறைகளுக்கு இணைப்பு ஆரோக்கியத்தை பராமரிப்பது தடையற்ற செயல்பாடுகளுக்கு அவசியம். போன்ற psycopg3 இன் கருவிகளுடன் conn.notifies(), டெவலப்பர்கள் வலுவான அறிவிப்பு அமைப்புகளை செயல்படுத்த முடியும். வழக்கமான சுகாதார சோதனைகள் பதிலளிக்காத இணைப்புகளைத் தவிர்க்க உதவும். செயலிழப்புகளைத் தடுக்க நேரடி புதுப்பிப்புகளுக்கான சரக்கு அமைப்புகளைக் கண்காணிப்பது எடுத்துக்காட்டுகளில் அடங்கும்.

அறிவிப்பு ஜெனரேட்டரை மூடுவது மற்றும் மீண்டும் திறப்பது, இலகுரக SQL கட்டளைகளுடன் இணைந்து, செயல்திறன் மற்றும் நம்பகத்தன்மை ஆகிய இரண்டையும் உறுதி செய்கிறது. லாஜிஸ்டிக்ஸ் புதுப்பிப்புகள் முதல் நிதி எச்சரிக்கைகள் வரை பல்வேறு பயன்பாட்டு நிகழ்வுகளுக்கு இந்த நுட்பங்கள் பொருந்தும். இத்தகைய உத்திகள் முக்கியமான பயன்பாடுகளை வேலையில்லா நேரத்திலிருந்து பாதுகாக்க உதவுகின்றன, தடையற்ற பயனர் அனுபவத்தை உறுதி செய்கின்றன. ⚡