পাইথনে zmq এর সাথে কাজ করার মৌলিক বিষয়, একটি সাধারণ কী/মান স্টোর তৈরি করা

ভূমিকা

আসুন একটি সাধারণ কী/মান সঞ্চয়ের উদাহরণ দেখি, যেমন মেমক্যাশ। এটি সহজভাবে ডিজাইন করা হয়েছে - ডেটা মেমরিতে, হ্যাশম্যাপ কাঠামোতে সংরক্ষণ করা হয়। এগুলি টিসিপি সকেটের মাধ্যমে অ্যাক্সেস করা হয়। পাইথনে, হ্যাশম্যাপ একটি নিয়মিত ডিক্ট। অ্যাক্সেসের জন্য আমরা zeromq ব্যবহার করব।

সমন্বয়

ডেবিয়ান/উবুন্টুতে এই প্যাকেজটি ইনস্টল করতে, শুধু কনসোলে প্রবেশ করুন
sudo apt-get install libzmq-dev
sudo pip install zmq

কোড

আমাদের সার্ভারের সাথে কাজ করার জন্য একটি ক্লাস লিখুন:
ব্যবহৃত zmq সকেটের ধরন হল REQ (অনুরোধ, অনুরোধ), আমরা একটি অনুরোধ পাঠাই এবং একটি প্রতিক্রিয়ার জন্য অপেক্ষা করি।
নেটওয়ার্কে যেকোনো ধরনের ডেটা সঞ্চয় ও প্রেরণ করতে, আমরা স্ট্যান্ডার্ড পিকল মডিউল ব্যবহার করি। কাজ "প্রটোকল" তিনটি মানের একটি টিপল: (কমান্ড, কী, ডেটা)

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, প্রতিক্রিয়া) ব্যবহার করা হয়েছে - আমরা অনুরোধের জন্য অপেক্ষা করছি, একটি প্রতিক্রিয়া পাঠাচ্ছি। আমরা অনুরোধটি পার্স করি এবং লেখার ক্ষেত্রে 'ঠিক আছে' দিয়ে, বা ডেটার সাথে / পড়ার ক্ষেত্রে কোনটিই নয়।

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