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

परिचय

साध्या की/व्हॅल्यू स्टोरेजचे उदाहरण पाहू, जसे की memcache. हे फक्त डिझाइन केले आहे - डेटा मेमरीमध्ये, हॅशमॅप स्ट्रक्चरमध्ये संग्रहित केला जातो. ते टीसीपी सॉकेटद्वारे प्रवेश करतात. पायथनमध्ये, हॅशमॅप हा नियमित शब्द आहे. प्रवेशासाठी आम्ही zeromq वापरू.

समायोजन

हे पॅकेज डेबियन/उबंटूमध्ये स्थापित करण्यासाठी, फक्त कन्सोलमध्ये प्रविष्ट करा
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'

वापरा

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

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

आता सर्व्हरच लिहू.
यावेळी सॉकेट REP(REPly, response) वापरला जातो - आम्ही विनंतीची वाट पाहत आहोत, प्रतिसाद पाठवत आहोत. आम्ही विनंतीचे विश्लेषण करतो आणि लेखनाच्या बाबतीत 'ठीक आहे' किंवा डेटासह / वाचनाच्या बाबतीत काहीही नाही.

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