पायथन में zmq के साथ काम करने की मूल बातें, एक सरल कुंजी/मूल्य स्टोर बनाना

परिचय

आइए एक साधारण कुंजी/मूल्य भंडारण का उदाहरण देखें, जैसे कि मेम्कैश। इसे सरलता से डिज़ाइन किया गया है - डेटा को हैशमैप संरचना में मेमोरी में संग्रहीत किया जाता है। उन तक टीसीपी सॉकेट के माध्यम से पहुंचा जा सकता है। पायथन में, हैशमैप एक नियमित निर्देश है। एक्सेस के लिए हम ज़ीरोएमक्यू का उपयोग करेंगे।

समायोजन

इस पैकेज को डेबियन/उबंटू में स्थापित करने के लिए, बस कंसोल में प्रवेश करें
sudo apt-get install libzmq-dev
sudo pip install zmq

कोड

आइए अपने सर्वर के साथ काम करने के लिए एक क्लास लिखें:
प्रयुक्त zmq सॉकेट का प्रकार REQ(REQuest, request) है, हम एक अनुरोध भेजते हैं और प्रतिक्रिया की प्रतीक्षा करते हैं।
नेटवर्क पर किसी भी प्रकार के डेटा को संग्रहीत और प्रसारित करने के लिए, हम मानक अचार मॉड्यूल का उपयोग करते हैं। कार्य "प्रोटोकॉल" तीन मानों का एक समूह है: (कमांड, कुंजी, डेटा)

import zmq
import pickle

class SuperCacher:
    def __init__(self):
        context = zmq.Context()
        self.socket = context.socket(zmq.REQ)
        self.socket.connect('tcp://127.0.0.1:43000')

    def get(self, key):
        self.socket.send(pickle.dumps(('get', key, None)))
        return pickle.loads(self.socket.recv())

    def set(self, key, data):
        self.socket.send(pickle.dumps(('set', key, data)))
        return self.socket.recv() == b'ok'

उपयोग

कैश = सुपरकैचर()
कैश.सेट('कुंजी', 'मान')
कैश.गेट('कुंजी')

होमवर्क के रूप में, कक्षा का उदाहरण बनाते समय पता/पोर्ट निर्दिष्ट करने की क्षमता जोड़कर कार्यान्वयन में सुधार करें।

अब सर्वर को ही लिखते हैं।
इस बार सॉकेट आरईपी (रिप्लाई, रिस्पांस) का उपयोग किया जाता है - हम अनुरोध की प्रतीक्षा कर रहे हैं, प्रतिक्रिया भेज रहे हैं। हम अनुरोध को पार्स करते हैं और लिखने के मामले में या तो 'ठीक' के साथ, या पढ़ने के मामले में डेटा/कोई नहीं के साथ जवाब देते हैं।

import pickle
import json
import zmq

def run_daemon():
    memory = {}

    context = zmq.Context()
    socket = context.socket(zmq.REP)
    socket.bind('tcp://127.0.0.1:43000')

    while True:
        try:
            command, key, data = pickle.loads(socket.recv())
            if command == 'set':
                memory[key] = data
                socket.send(b'ok')
            elif command == 'get':
                result = memory.get(key, None)
                socket.send(pickle.dumps(result))
        except Exception as e:
            print(e)

if __name__ == '__main__':
    run_daemon()

सब कुछ एक साथ जांचने के लिए, हम सर्वर को कमांड से शुरू करते हैं
python daemon.py

अगले टैब में, इंटरैक्टिव मोड में पायथन लॉन्च करें।

>>> from lib import SuperCacher
>>> cache=SuperCacher()
>>> cache.set('key', 'value')
True
>>> cache.get('key')
'value'

ओह चमत्कार, यह काम करता है! अब आप अपने बायोडाटा में सुरक्षित रूप से "zmq प्रोटोकॉल का उपयोग करके कुंजी-मूल्य भंडारण का विकास" लिख सकते हैं।

स्रोत: www.habr.com