如何将对象从Python中的一个程序传递到另一个程序

如何解决如何将对象从Python中的一个程序传递到另一个程序

我正在使用PIKA Python客户端进行RabbitMQ消息交换框架。

在一个Python程序上： 我正在发送消息请求以删除客户端 我是在Node-RED的背景下完成的

远程客户端响应后，将调用注册的回叫。 此响应将有一个对象，我需要将其传递回NODE RED

我该如何实现？ 请注意流程：

程序＃1 节点RED-> Python Program1 ==>发送RabbitMQ消息->注册回调函数

程序＃2 远程客户端发送响应->已执行已注册的回叫->，但是它无权访问NODE RED消息队列详细信息。因此，无法将响应对象直接从此处发回给node-red

我需要做的是将一个响应对象共享回Program＃1中。 我可以等一些事件-

PS：进程1不是由进程1创建的-因为回调是独立调用的

这是我的代码-

"""
Following statement declares an exchange that is direct type.
Each message sent to direct exchange will be copied only to the
queue bound to that exchange
"""
channel.exchange_declare(exchange='test-direct',exchange_type='direct')

"""
Create a queue dynamically and wait on the queue 
"""
channel.queue_declare(queue="test1")

"""
Bind this queue to a direct exchange,so that the reply messages sent
to this queue are consumed only by server - not fanned out
"""
channel.queue_bind(exchange='test-direct',queue="test1")

channel.basic_publish(exchange="test-direct",routing_key=ipaddress,properties=pika.BasicProperties(
reply_to="test1"),body=str(msg_tobe_sentto_remote_hosts))

channel.basic_consume(
queue="test1",on_message_callback= ProcessReceivedMessage,auto_ack=True)
logger.info(' [*] Waiting for messages. To exit press CTRL+C')

try:
channel.start_consuming()
except KeyboardInterrupt:
logger.critical("Keyboard Interrupt Received --exiting")
channel.close()
exit
return msg
"""
Function name: ProcessReceivedMessage
"""
def ProcessReceivedMessage (ch,method,properties,body):
body = body.decode('utf-8')
logger.info("Inside ProcessReceivedMessage ")
logger.info (body)
return(body)

现在我的问题是，上面声明队列的第一个函数将其绑定等等，-我希望该函数能够接收已成为第二个函数“ ProcessReceivedMEssage”的消息的消息。 我该怎么办？

TLDR：回调函数接收到的消息要发送到原始函数