使用 Lambda 函数处理 AWS IoT 消息

Question

我正在尝试在 C# 中开发一个 lambda 函数来处理和转换从 AWS IoT 核心接收到的数据，就像处理来自 DynamoDB、S3 或 SQS 的数据一样。

我想知道的是我是否必须强制订阅主题，转换每条消息并最终将其发送到 s3、DyanmoDB 或其他任何东西，或者我可以直接访问这些数据而无需订阅。

代码：

 var CaCert = X509Certificate.CreateFromCertFile(@"C:\...\rootCA.pem");
                var clientCert = new X509Certificate2(@"C:\...\amazon.pfx");
                string ClientID = Guid.NewGuid().ToString();


                var IotClient = new MqttClient(IotEndPoint, BrokerPort, true, CaCert, clientCert, MqttSslProtocols.TLSv1_2);
                IotClient.MqttMsgPublishReceived += Client_MqttMsgPublishReceived;

                IotClient.Connect(ClientID);
                Console.WriteLine("Connected to IoT Core. Waiting for the frames...");
                IotClient.Subscribe(new string[] { topic }, new byte[] { MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE });

Answer 1

您必须订阅主题才能访问数据。但是，您可以简单地编写您的主题订阅 SQL 表达式以使用像 this example from the official documentation 这样的通配符，以避免订阅每个单独的主题：

您可以使用 # 通配符来匹配主题中的任何子路径 过滤器：

例子：

在主题“a/b”上发布的传入负载：{温度：50}。

在主题“a/c”上发布的传入负载：{温度：60}。

在主题“a/e/f”上发布的传入负载：{temperature: 70}。

在主题“b/x”上发布的传入负载：{温度：80}。

SQL: "SELECT temperature AS t FROM 'a/#'".

该规则订阅任何以“a”开头的主题，所以它是 执行 3 次，发送 {t: 50} 的传出有效载荷（对于 a/b）， {t: 60}（用于 a/c）和 {t: 70}（用于 a/e/f）对其操作。它不是 订阅了'b/x'，所以规则不会被触发 {温度：80} 消息。