पायथनमध्ये zmq सह काम करण्याची मूलभूत माहिती, एक साधी की/व्हॅल्यू स्टोअर तयार करणे

परिचय

चला memcache सारख्या साध्या की/व्हॅल्यू स्टोअरचे उदाहरण पाहू. ते सोप्या पद्धतीने डिझाइन केले आहे: डेटा मेमरीमध्ये हॅशमॅप स्ट्रक्चरमध्ये साठवला जातो. तो TCP सॉकेटद्वारे अॅक्सेस केला जातो. पायथनमध्ये, हॅशमॅप हा एक नियमित डिक्ट आहे. अॅक्सेससाठी आपण zeromq वापरू.

समायोजन

हे पॅकेज इंस्टॉल करण्यासाठी debian/ubuntu फक्त कन्सोलमध्ये प्रविष्ट करा
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'

वापरा

कॅशे = सुपरकॅचर()
कॅशे.सेट('की', 'मूल्य')
कॅशे.गेट('की')

गृहपाठ असाइनमेंट म्हणून, वर्गाचा एक उदाहरण तयार करताना पत्ता/पोर्ट निर्दिष्ट करण्याची क्षमता जोडून अंमलबजावणी सुधारा.

आता आपण ते स्वतःच लिहू. सर्व्हर.
यावेळी, आम्ही REP(REPly, प्रतिसाद) सॉकेट वापरतो—आम्ही विनंतीची वाट पाहतो आणि प्रतिसाद पाठवतो. आम्ही विनंतीचे विश्लेषण करतो आणि लिहिण्यासाठी 'ok' किंवा वाचण्यासाठी डेटा/None असे उत्तर देतो.

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

पुढील टॅबमध्ये, Python इंटरॅक्टिव्ह मोडमध्ये लाँच करा.

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

चमत्कारिकरित्या, ते काम करते! आता तुम्ही तुमच्या रेझ्युमेवर "zmq प्रोटोकॉल वापरुन की-व्हॅल्यू स्टोरेज डेव्हलपमेंट" आत्मविश्वासाने लिहू शकता.

स्त्रोत: www.habr.com