Google Cloud Pub/Sub客户端

Google Cloud Pub/Sub客户端库，用Rust编写。目前支持发布、拉取和确认，但不支持创建主题或订阅等管理任务。

消息可以是原始的发布/拉取，或者如果负载是JSON数据，则可以通过Serde和Serde JSON序列化为/反序列化为领域消息（结构体或枚举）。原始的RawPulledMessage和“类型化”的PulledMessage都公开了元数据，如消息ID、确认ID、属性等。

除了直接的反序列化外，还可能首先转换拉取的JSON值，然后再将其反序列化为领域消息，这允许通常调整JSON结构以及模式演变。

用法

通常我们想使用领域消息

#[derive(Debug, Serialize, Deserialize)]
struct Message {
    text: String,
}

要发布Message，我们需要派生Serialize，要拉取它，我们需要派生Deserialize。

首先创建一个PubSubClient，提供服务账户密钥文件的路径以及在访问令牌过期前刷新访问令牌的持续时间

let pub_sub_client = PubSubClient::new(
    "secrets/cryptic-hawk-336616-e228f9680cbc.json",
    Duration::from_secs(30),
)?;

可能会出错，例如，如果服务账户密钥文件不存在或格式不正确，因此返回一个Result。

然后我们调用publish来使用给定的TOPIC_ID发布一些messages，如果一切顺利，则返回消息ID；我们在此处和以下不使用排序键或请求超时以简化

let messages = vec!["Hello", "from pub-sub-client"]
    .iter()
    .map(|s| s.to_string())
    .map(|text| Message { text })
    .collect::<Vec<_>>();
let message_ids = pub_sub_client
    .publish(TOPIC_ID, messages, None, None)
    .await?;
let message_ids = message_ids.join(", ");
println!("Published messages with IDs: {message_ids}");

接下来我们调用pull来从给定的SUBSCRIPTION_ID获取最多给定的42条消息

let pulled_messages = pub_sub_client
    .pull::<Message>(SUBSCRIPTION_ID, 42, None)
    .await?;

for pulled_message in pulled_messages {
    match pulled_message.message {
        Ok(m) => println!("Pulled message with text \"{}\"", m.text),
        Err(e) => eprintln!("ERROR: {e}"),
    }

    pub_sub_client
        .acknowledge(SUBSCRIPTION_ID, vec![&pulled_message.ack_id], None)
        .await?;
    println!("Acknowledged message with ID {}", pulled_message.id);
}