Asyncio में ZeroMQ और PostgreSQL के साथ काम करना

शायद हर कोई अद्भुत asyncio पुस्तकालय के बारे में सुना है?

यदि नहीं, तो संक्षेप में: यह पुस्तकालय पायथन में अतुल्यकालिक नेटवर्क प्रोग्रामिंग के लिए मानक बन गया है। बवंडर और मुड़ या तो उसके साथ काम करना सीखेंगे या धीरे-धीरे हाशिए पर चले जाएंगे।

एसिंकोयो महान है, लेकिन यह टीसीपी , यूडीपी , यूनिक्स सॉकेट्स, पीआईपीईएस के साथ काम करने के लिए सिर्फ एक पुस्तकालय है , और अतुल्यकालिक रूप से उपप्रकार चल रहा है।

सभी को महान होने के लिए, उन्हें तीसरे पक्ष के पुस्तकालयों की आवश्यकता होती है जो एसिंको के साथ काम कर सकते हैं। कुछ पहले से ही है, लेकिन पर्याप्त नहीं है।

इसलिए मैंने अपने सहयोगियों के साथ एक जोड़ी बनाई: एक जीरोएमक्यू के लिए और दूसरा पोस्टग्रेक्यूएल के लिए

यदि आप दृढ़ता से अजगर 2 पर बैठते हैं और अजगर 3 में दिलचस्पी नहीं रखते हैं - बेवकूफ सवालों और अन्य गलतफहमी से बचने के लिए कट के नीचे मत जाओ ।


मुझे इसकी आवश्यकता क्यों थी?

क्योंकि हम एक नई परियोजना शुरू कर रहे हैं जिसमें ZeroMQ और Postgress अपरिहार्य है। मैं asyncio पर करना चाहते हैं। मुझे लापता टुकड़ों को काटना पड़ा।

मुझे तुरंत कहना होगा कि दोनों ठोस हैं। मैं पायथन कोर डेवलपर हूं और asyncio कोड में भी मेरा बहुत काम है। मुझे लगता है कि मैं समझ गया कि एक प्रणाली के लिए लिखना कितना अच्छा है जिसे मैंने खुद बनाने में मदद की।

प्लस (लगभग) परीक्षण और स्पष्ट (मुझे आशा है) प्रलेखन के साथ दोनों पुस्तकालयों के कोड का 100% कवरेज।

aiozmq - आप asyncio के साथ ZeroMQ सॉकेट का उपयोग करने की अनुमति देता है।

प्रलेखन यहाँ है ।

aiozmq निम्न-स्तरीय ZeroMQ सॉकेट्स के साथ काम करता है और, सबसे महत्वपूर्ण बात, बॉक्स से बाहर रिमोट प्रोसीजर कॉल तंत्र (प्लस पबसब और नोटिफाई) देता है।

एक छोटा उदाहरण:

import asyncio import aiozmq import aiozmq.rpc class ServerHandler(aiozmq.rpc.AttrHandler): @aiozmq.rpc.method def remote_func(self, a:int, b:int) -> int: return a + b @asyncio.coroutine def go(): server = yield from aiozmq.rpc.start_server( ServerHandler(), bind='tcp://127.0.0.1:5555') client = yield from aiozmq.rpc.open_client( connect='tcp://127.0.0.1:5555') ret = yield from client.rpc.remote_func(1, 2) assert 3 == ret server.close() client.close() asyncio.set_event_loop_policy(aiozmq.ZmqEventLoopPolicy()) asyncio.get_event_loop().run_until_complete(go()) 

अब चलो aiopg पर चलते हैं

यह lib psynopg2 के साथ अतुल्यकालिक मोड में काम कर सकता है और एक अच्छा बोनस के रूप में एक कनेक्शन पूल देता है

प्रलेखन यहाँ है ।

  @asyncio.coroutine def test_select(): pool = yield from aiopg.create_pool(dsn) with (yield from pool.cursor()) as cur: yield from cur.execute('SELECT 1') ret = yield from cur.fetchone() assert ret == (1,), ret 

दोनों पुस्तकालय GitHub पर पोस्ट किए गए हैं: aiozmq और aiopg

यदि आपको यह पसंद है तो इसे आज़माएं - इसका उपयोग करें।

बग ढूंढें - मुद्दों में गीथूब पर लिखें, और इससे भी बेहतर है कि तुरंत अनुरोध करें