zbus-python-client

pip install zbuspy

from zbus import MqClient, Message

def onopen(client):
    msg = Message()
    msg.headers.cmd = 'pub'
    msg.headers.mq = 'MyMQ'
    msg.body = 'hello from python'

    client.invoke(msg, lambda res: print(res) )

client = MqClient('localhost:15555')
client.onopen = onopen
client.connect()

from zbus import MqClient, Message

mq = 'MyMQ'
channel = 'MyChannel'

def create_mq(client):
    msg = Message()
    msg.headers.cmd = 'create'
    msg.headers.mq = mq
    msg.headers.channel = channel 
    
    client.invoke(msg, lambda res: print(res)) #lambda

def onopen(client):
    
    create_mq(client)
    
    msg = Message()
    msg.headers.cmd = 'sub' #sub on channel of mq
    msg.headers.mq = mq
    msg.headers.channel = channel 
    
    def cb(res):
        print(res)
    
    client.invoke(msg, cb)

def message_handler(msg):
    print(msg)

client = MqClient('localhost:15555')
client.onopen = onopen
client.add_mq_handler(mq, channel, message_handler)
client.connect() 

from zbus import RpcClient   
rpc = RpcClient('localhost:15555', mq='MyRpc')

res = rpc.example.plus(1,2) 
print(res)

rpc.close()

from zbus import RpcServer, Message, RequestMapping


class MyService: 
    
    def echo(self, ping):
        return str(ping)
    
    def getString(self, s):
        return str(s)
        
    def plus(self, a, b):  
        return int(a) + int(b) 
    
    def testEncoding(self, msg): #msg -- request message
        print(msg)
        return u'中文'
    
    def noReturn(self):
        pass
    
    def home(self):
        res = Message()
        res.status = 200
        res.headers['content-type'] = 'text/html; charset=utf8'
        res.body = '<h1> from Python </h1>'
        return res
    
    def getBin(self):
        b = bytearray(10)
        import base64
        return base64.b64encode(b).decode('utf8')
    
    def throwException(self):
        raise Exception("runtime exception from server")
    
    @RequestMapping(path='/m', method='POST') #change path
    def map(self): 
        return {
            'key1': 'mykey',
            'key2': 'value2',
            'key3': 2.5
        } ```