PostgreSQL व्यंजनों: अतुल्यकालिक कार्य समयबद्धक

अतुल्यकालिक कार्य अनुसूचक तैयार करने के लिए, हमें खुद को और इसके एक्सटेंशन pg_task को पोस्टग्रेज करने की आवश्यकता है। (मैंने अपने कांटे के पोस्टग्रास के लिंक दिए, क्योंकि मैंने कुछ बदलाव किए हैं जो अभी तक मूल भंडार में रटना नहीं कर पाए हैं। आप तैयार छवि का भी उपयोग कर सकते हैं।)

(मूल PostgreSQL में PL / pgSQL में एक त्रुटि है, जिसके कारण मेरे अनुसूचक सही ढंग से काम नहीं करता है जब PL / pgSQL में लिखे गए किसी कार्य में कोई अपवाद नहीं होता है। मैंने इस त्रुटि का यहाँ वर्णन किया है और इसे यहाँ मेरे ink में ठीक किया है ।)

अनुसूचक को स्थापित करने के लिए, आपको (प्रत्येक) डेटाबेस में एक्सटेंशन बनाने की आवश्यकता नहीं है। इसके बजाय, इसे कॉन्फ़िगरेशन फ़ाइल में जोड़ें

shared_preload_libraries = 'pg_task' 

PostgreSQL को पुनरारंभ करने के बाद, शेड्यूलर डेटाबेस उपयोगकर्ताओं की ओर से और इन उपयोगकर्ताओं के लिए डिफ़ॉल्ट स्कीमा में सभी डेटाबेस में कार्य सारणी बनाएगा।

यदि आप शेड्यूलर को केवल विशिष्ट डेटाबेस के लिए चलाना चाहते हैं, तो आप उन्हें कॉन्फ़िगरेशन फ़ाइल में निर्दिष्ट कर सकते हैं

 pg_task.database = 'database1,database2' 

यदि आप डेटाबेस उपयोगकर्ताओं से शेड्यूलर को चलाना चाहते हैं, तो इसे भी सेट किया जा सकता है

 pg_task.database = 'database1:user1,database2:user2' 

यदि आपको उपयोगकर्ताओं के लिए डिफ़ॉल्ट योजना में नहीं शेड्यूलर टेबल बनाने की आवश्यकता है, तो आप इसे इस तरह सेट कर सकते हैं

 pg_task_schema.database1 = schema3 

यदि आपको अनुसूचक तालिका को अलग से नाम देने की आवश्यकता है, तो आप इसे इस तरह से कर सकते हैं

 pg_task_table.database1 = table3 

डिफ़ॉल्ट रूप से, शेड्यूलर प्रत्येक 1000 एमएस में कार्यों की जांच करता है, लेकिन इसे निम्नानुसार बदला जा सकता है

 pg_task_period.database1 = 100 pg_task_period.database2 = 10 

तो, शेड्यूलर (यदि पहले से निर्मित नहीं है) (एक योजना, यदि आवश्यक हो, और) ऐसे स्तंभों के साथ एक कार्य तालिका

 id BIGSERIAL NOT NULL PRIMARY KEY, -- ,   dt TIMESTAMP NOT NULL DEFAULT NOW(), --     (- -   ) start TIMESTAMP, --     stop TIMESTAMP, --      queue TEXT NOT NULL DEFAULT 'default', --    (      ) max INT, --        (,      ) pid INT, --  ,    request TEXT NOT NULL, --  SQL   response TEXT, --    state TEXT NOT NULL DEFAULT 'QUEUE', --   (- - ,    , , ...) timeout INTERVAL, --      delete BOOLEAN NOT NULL DEFAULT false, --     ,    repeat INTERVAL, --    drift BOOLEAN NOT NULL DEFAULT true --        

वास्तव में, शेड्यूलर कई पृष्ठभूमि वर्कफ़्लो शुरू करता है: एक कॉन्फ़िगरेशन फ़ाइल में परिवर्तन को ट्रैक करने और प्रारंभ करने / रोकने के लिए, यदि आवश्यक हो, तो शेड्यूलर की अन्य पृष्ठभूमि प्रक्रियाएं। और प्रत्येक डेटाबेस में निर्धारित कार्यों की जाँच करने और यदि आवश्यक हो तो कार्यों को लॉन्च करने के लिए प्रत्येक डेटाबेस के लिए एक पृष्ठभूमि वर्कफ़्लो।

उदाहरण के लिए, यदि हम कार्य को जल्द से जल्द पूरा करना चाहते हैं, तो हम SQL कमांड को निष्पादित करते हैं

 INSERT INTO task (request) VALUES ('SELECT now()') 

शेड्यूलर कार्य के परिणाम को टेक्स्ट फॉर्म में परिणाम कॉलम में लिखता है। यदि कार्य निष्पादन के परिणामस्वरूप कई कॉलम हैं, तो शेड्यूलर उन्हें कॉलम प्रकारों के साथ हेडर में जोड़ देगा। इसके अलावा, कार्य के परिणामस्वरूप, कई लाइनें हो सकती हैं, उन सभी को परिणाम कॉलम में जोड़ा जाएगा।

यदि हम किसी कार्य को पूरा करना चाहते हैं, उदाहरण के लिए, 5 मिनट के बाद, तो हम योजनाबद्ध समय को संबंधित कॉलम में लिखते हैं

 INSERT INTO task (dt, request) VALUES (now() + '5 min':INTERVAL, 'SELECT now()') 

और यदि हम चाहते हैं कि कार्य एक निश्चित समय में पूरा हो जाए, तो हम इसे लिख देंगे

 INSERT INTO task (dt, request) VALUES ('2019-07-01 00:00:00', 'SELECT now()') 

अगर हमें हर 5 मिनट में कार्य करने की आवश्यकता है, तो हम इस तरह लिखते हैं

 INSERT INTO task (repeat, request) VALUES ('5 min', 'SELECT now()') 

अगर ऐसा है तो लिखें

 INSERT INTO task (repeat, request, drift) VALUES ('5 min', 'SELECT now()', false) 

तब कार्य पूरा होने के 5 मिनट बाद (और निर्धारित समय के बाद नहीं, डिफ़ॉल्ट रूप से) दोहराया जाएगा।

यदि किसी कार्य के निष्पादन के दौरान अपवाद होता है, तो उसे परिणाम स्तंभ पर पाठ रूप में लिखा और लिखा जाता है, और संबंधित स्थिति को कार्य सौंपा जाता है।

उदाहरण के लिए

 INSERT INTO task (request) VALUES ('SELECT 1/0') 

यदि यह आवश्यक है कि कार्य कतार के लिए 2 से अधिक कार्यों को एक साथ निष्पादित नहीं किया जाता है, तो हम कमांड द्वारा कार्य बनाते हैं

 INSERT INTO task (queue, max, request) VALUES ('queue', 2, 'SELECT now()') 

मान लीजिए कि इस कतार में हमने बहुत सारे कार्य संचित कर लिए हैं और वे एक साथ 2 द्वारा निष्पादित किए जाते हैं। यदि आप कमांड के साथ कोई कार्य बनाते हैं

 INSERT INTO task (queue, max, request) VALUES ('queue', 3, 'SELECT now()') 

फिर इसे इस कतार में अन्य सभी कार्यों के लिए यथाशीघ्र क्रियान्वित किया जाएगा, अर्थात यह अभी भी प्राथमिकता की तरह कुछ है