Rust应用程序如何向打算到达设备的IoTHub发送云到设备的消息？

Question

我正在构建一个基于MQTT的Rust应用程序，该应用程序向IoTHub发送消息，以便将消息转发到监听云到设备消息的目标设备。

目标设备“myDev”订阅了主题devices/myDev/messages/devicebound/#，它可以从IoTHub接口（“Azure门户上的消息到设备”）接收消息。

我发现的用其他编程语言实现这一点的示例使用Azure IoT SDK，它有一个客户端服务。例如，参见Java示例：https://docs.microsoft.com/en-us/azure/iot-hub/iot-hub-java-java-c2d#send-a-cloud-to-device-message

问题是，目前还没有官方的Azure IoT SDK。我只能找到这个项目https://github.com/damienpontifex/azure-iot-sdk-rs我不能用它，因为它和Tokio有依赖关系

然而，我可以想象向IoTHub发送云到设备的消息一定是可行的。所需信息可能是：device_id、body和属性，它们是界面中可用的字段。

但我还没有找到更多的细节。感谢您的帮助。

Answer 1

事实上，没有官方的SDK——但您可以查看其他一些实现，比如下面的示例：

use tokio::time;
use azure_iot_sdk::{IoTHubClient, DeviceKeyTokenSource, Message};

#[tokio::main]
async fn main() -> azure_iot_sdk::Result<()> {
    let iothub_hostname = "iothubname.azure-devices.net";
    let device_id = "MyDeviceId";
    let token_source = DeviceKeyTokenSource::new(
        iothub_hostname,
        device_id,
        "TheAccessKey",
    ).unwrap();

    let mut client =
        IoTHubClient::new(iothub_hostname, device_id.into(), token_source).await?;

    let mut interval = time::interval(time::Duration::from_secs(1));
    let mut count: u32 = 0;

    loop {
        interval.tick().await;

        let msg = Message::builder()
            .set_body(format!("Message #{}", count).as_bytes().to_vec())
            .set_message_id(format!("{}-t", count))
            .build();

        client.send_message(msg).await?;

        count += 1;
    }

    Ok(())
}

或者，如果Rust不是一项硬性要求，至少是端到端的要求，那么您可以拥有一个独立的服务来处理IoT Hub的操作，并将其作为正常的REST服务从您的Rust代码中调用。