gcp-pubsub

一个用作 HTTP 客户端以向 Google Cloud Platform 的 PubSub 发布和读取消息的 crate。

用法

创建客户端

认证由 rust-goauth 提供，它期望一个包含您的 Google Cloud 服务帐户 JSON 密钥文件的路径。

let google_credentials = std::env::var("GOOGLE_PUBSUB_CREDENTIALS").unwrap();
let mut client = gcp_pubsub::Client::new(credentials);

创建主题

let topic = client.create_topic("my-topic").await;

发布消息

#[derive(Serialize, Default)]
struct Foo {
  pub a: String,
}

let result: Result<(), Error> = topic.publish(Foo::default()).await;

读取消息

let subscription = topic.create_subscription().await.unwrap();
let messages : Result<Vec<gcp_pubsub::Message>, Error> = subscription.pull().await;