跳到主要内容

Python API开发者指南

Solace PubSub+ Python消息API(版本1.10)提供了现代的开发模式和易用性。Solace PubSub+ Python API允许您的应用程序充分利用Solace事件代理的功能集。

Solace PubSub+ Python消息API使用构建器模式,允许您轻松创建一个MessagingService实例,并使用属性对其进行自定义配置,然后连接到事件代理。成功建立连接后,您可以使用Python API发送和接收消息。

在您设置好环境后,以下是使用Solace PubSub+ Python消息API的概述:

  1. 构建一个MessagingService实例,并使用属性对其进行配置,以:
    • 连接到事件代理,例如主机名和消息VPN
    • 使用代理(如HTTP或SOCKS5)连接到主机事件代理。
    • 设置连接属性,例如TLS或压缩
    • 选择认证方案以认证到事件代理
  2. 使用以下方式向事件代理发送消息或从事件代理接收消息:

在创建消息发布者或消息消费者时,您可以配置如何处理发生反压的情况。有关详细信息,请参阅以下各节。

  • 使用DirectMessagePublisher发布直接消息。有关详细信息,请参阅使用Python API发布直接消息。

  • 使用PersistentMessagePublisher发布持久消息(保证消息)。有关详细信息,请参阅使用Python API发布持久消息。

  • 使用DirectMessageReceiver从事件代理消费直接消息。有关详细信息,请参阅使用Python API消费直接消息。

  • 使用PersistentMessageReceiver消费持久消息(保证消息),请参阅使用Python API消费持久消息。

  1. 在发布或消费消息的过程中,使用OutboundMessageInboundMessage(通过事件处理器),并通过事件处理器按需处理错误。

Solace PubSub+消息API中的消息发布者还允许您处理内部缓冲区中消息积压的情况,这被称为反压。例如,在发送消息的客户端应用程序中,可能会出现客户端应用程序生成消息的速度快于消息可以发送到事件代理的速度的情况,这可能是由于网络拥塞等因素造成的。Solace PubSub+消息API中的直接消息接收器不能应用反压,但可以选择它们对慢速应用程序的反应方式。当内部缓冲区中积压了太多消息时,您可以告诉直接消息接收器丢弃来自发布者的最早或最新的消息。

您可以参考各种示例应用程序,以了解如何使用我们的Python API。有关详细信息,请查看本指南的相关部分,以及Solace PubSub+ Python API参考和Solace Python API GitHub页面上的Python示例代码。