python ਵਿੱਚ zmq ਨਾਲ ਕੰਮ ਕਰਨ ਦੀਆਂ ਬੁਨਿਆਦੀ ਗੱਲਾਂ, ਇੱਕ ਸਧਾਰਨ ਕੁੰਜੀ/ਮੁੱਲ ਸਟੋਰ ਬਣਾਉਣਾ

ਜਾਣ ਪਛਾਣ

ਆਉ ਇੱਕ ਸਧਾਰਨ ਕੁੰਜੀ/ਮੁੱਲ ਸਟੋਰੇਜ਼ ਦੀ ਇੱਕ ਉਦਾਹਰਨ ਵੇਖੀਏ, ਜਿਵੇਂ ਕਿ ਮੇਮਕੈਸ਼। ਇਹ ਸਧਾਰਨ ਰੂਪ ਵਿੱਚ ਤਿਆਰ ਕੀਤਾ ਗਿਆ ਹੈ - ਡੇਟਾ ਨੂੰ ਮੈਮੋਰੀ ਵਿੱਚ, ਹੈਸ਼ਮੈਪ ਢਾਂਚੇ ਵਿੱਚ ਸਟੋਰ ਕੀਤਾ ਜਾਂਦਾ ਹੈ। ਉਹਨਾਂ ਨੂੰ ਇੱਕ tcp ਸਾਕਟ ਦੁਆਰਾ ਐਕਸੈਸ ਕੀਤਾ ਜਾਂਦਾ ਹੈ। ਪਾਈਥਨ ਵਿੱਚ, ਹੈਸ਼ਮੈਪ ਇੱਕ ਨਿਯਮਿਤ ਡਿਕਟ ਹੈ। ਪਹੁੰਚ ਲਈ ਅਸੀਂ 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

ਅਗਲੀ ਟੈਬ ਵਿੱਚ, python ਨੂੰ ਇੰਟਰਐਕਟਿਵ ਮੋਡ ਵਿੱਚ ਲਾਂਚ ਕਰੋ।

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

ਓ ਚਮਤਕਾਰ, ਇਹ ਕੰਮ ਕਰਦਾ ਹੈ! ਹੁਣ ਤੁਸੀਂ ਸੁਰੱਖਿਅਤ ਢੰਗ ਨਾਲ ਆਪਣੇ ਰੈਜ਼ਿਊਮੇ ਵਿੱਚ "zmq ਪ੍ਰੋਟੋਕੋਲ ਦੀ ਵਰਤੋਂ ਕਰਦੇ ਹੋਏ ਮੁੱਖ-ਮੁੱਲ ਸਟੋਰੇਜ ਦਾ ਵਿਕਾਸ" ਲਿਖ ਸਕਦੇ ਹੋ।

ਸਰੋਤ: www.habr.com