如何将RPC与Volttron配合使用 [英] How to use RPC with Volttron

问题描述

我希望在我的Volttron应用程序中使用RPC调用，但我无法使任何调用工作。所有呼叫均失败，并显示"无路由至主机"错误

<stderr> ERROR: Unreachable: VIP error (113): No route to host: rpcserver.agent_1

本质上有两个代理，一个导出RPC过程的"服务器"代理，以及一个调用该过程的"客户端"代理。

在"服务器"代理中，我导出了代理类的一个方法，如下所示：

@RPC.export('setConfig')
def setConfig(self, config):
    self.config = config                       
    self.initialize_device()

客户端代理按如下方式调用导出的方法：

self.vip.rpc.call(sender, 'setConfig', self.config[sender]).get()

其中，"sender"是"服务器"代理的VIP标识(原来是"rpcserver.agent_1"，对应于从rpcserver.agent接收发布订阅消息时的"sender"参数的值。我已在标识文件中将标识定义为rpcserver.agent_{n})。

我的问题是： 1.为了正确设置RPC子系统，我是否做了一些明显的错误或遗漏了某些步骤？ 2.self.vip.rpc.call(peer, method, ...)中的"Peer"参数是否预期为代理的身份？这在文档中不清楚(我尝试了其他选项，如代理名称或UUID，但都不起作用)

我在Ubuntu VM上运行的是volttron 5.1.0。

在这方面的任何帮助都将不胜感激。 致以最良好的问候

详细信息：

这适用于互连多个设备的控制应用程序。代理根据网络中的可用设备动态加载。我想尝试使用RPC，而不是只使用pubSub。到目前为止，我已经相当彻底地搜索了Volttron代码和文档，以获取有关RPC API的详细信息，但一无所获。

最小"服务器"类：

class rpcServerAgent(Agent):    
    def __init__(self, config, **kwargs):        
        super(rpcServerAgent, self).__init__(**kwargs)
        self.config = config

    @Core.receiver('onstart')
    def onstart(self, sender, **kwargs):                     
        self.vip.rpc.export(self.setConfig, name='setConfig')           # Also tried online exporting 

        # Ask the client to call the exported procedure
        myutils.publish(self, topic='rpc/test', message={})             # myutils.publish publishes the message on pubsub 


    @RPC.export('setConfig')
    def setConfig(self, config):
        self.config = config        
        self.initialize_device()
        myutils.publish(self, topic='rpc/clientready')

    def initialize_device(self):
        pass

最小"客户端"类：

class rpcClientAgent(Agent):    
    def __init__(self, config, **kwargs):
        super(rpcClientAgent, self).__init__(**kwargs)        
        self.config = {'rpcclient.agent_1': {'a': 0, 'b': 1}}                   # dummy config for rpcclient.agent

    @Core.receiver('onstart')
    def onstart(self, sender, **kwargs):
        self.vip.pubsub.subscribe(peer='pubsub',
                                prefix='rpc',
                                callback=self.__handle_request__).get(timeout=5)      

    def call_RPC(self, sender):        
        sender = sender.strip()         # volttron adds a newline at the end        
        self.vip.rpc.call(sender, 'setConfig', self.config[sender]).get()       # assume that self.config[sender] is well-defined    

    @PubSub.subscribe('pubsub', 'rpc')
    def __handle_request__(self, peer, sender, bus, topic, headers, message):
        try:
            msg = json.loads(message)
        except:
            raise ValueError("failed to decode message")

        topics = topic.split('/')
        if len(topics) > 1:
            if topics[0] == 'rpc':                
                if topics[1] == 'test':                                                            
                    self.call_RPC(sender)

预期行为：调用导出的函数并发布主题为"RPC/ClientReady"的发布消息。

实际行为：RPC调用失败，错误为"Unreacable：VIP Error(113)：No Routing to host：rpcclient.agent_1"

编辑 我最终发现问题在于Volttron内部的代理身份以‘’结尾 ‘性格。这是因为Gedit自动添加了它，显然，字符串没有被Volttron剥离。

rpc

关于如何创建一个推荐答案方法，我想说您已经正确地做了一些事情(尽管：

@RPC.export('setConfig')

可能是：

@RPC.export

因为您没有更改方法名称)。

就进行RPC调用而言，第一个参数实际上是代理标识或地址。

如果您想查看更多示例，请查看services/core/MasterDriverAgent/master_driver/interfaces.

中的MODBUS或BACnet驱动程序

其他几点注意事项：

• 配置存储可用于设置代理配置。这方面的例子可以在volttron/Platform/agent/base_weather.py(以及许多其他代理)中找到

• 虽然我不是很熟悉，但您尝试做的事情似乎可以通过利用主驱动程序的功能来实现。我相信Market Service代理可能与您正在尝试实现的目标具有相同的设计功能，它可以在Services/core/MarketServiceAgent中找到。

这篇关于如何将RPC与Volttron配合使用的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！