当前位置: 首页 > 知识库问答 >
问题:

将来自AWS IOT核心的MQTT主题名称转换为AWS Lambda.NET核心

陆洲
2023-03-14

我需要帮忙。因此,我需要从AWS Lambda获得从AWS IOT Core订阅(触发)的主题名称。这是我的lambda代码

        public string FunctionHandler(Gps message, ILambdaContext context)
    { 
        LambdaLogger.Log("STRING MESSAGE DT: " + message.dt);
        LambdaLogger.Log("STRING MESSAGE LN: " + message.ln);
        LambdaLogger.Log("STRING MESSAGE LT: " + message.lt);
        LambdaLogger.Log("input context: " + context.FunctionName);
        LambdaLogger.Log("input context: " + context.Identity);
        LambdaLogger.Log("input context: " + context.InvokedFunctionArn);
        LambdaLogger.Log("input context: " + context.FunctionName);
        LambdaLogger.Log("input context: " + context.AwsRequestId);
        LambdaLogger.Log("input context: " + context.ClientContext);
        LambdaLogger.Log("input context: " + context.Logger);
        LambdaLogger.Log("input context: " + context.LogStreamName);
        return JsonConvert.SerializeObject(gpsList);
    }

我在云观察中看到,我正确地接收了来自MQTT的有效负载数据,并正确地触发了。所以这就是我的主题:

AWS/#
{
        "dt": "2020-02-26 18:03:30",
        "lt": "xxx.xxx",
        "ln": "yyy.yyy"
}
SELECT *, topic() as Topic FROM 'AWS/#'
2021-04-20T09:26:48.457+02:00   STRING MESSAGE DT: 2020-02-26 18:03:30

2021-04-20T09:26:48.473+02:00   STRING MESSAGE LN: xxx.xxx

2021-04-20T09:26:48.473+02:00   STRING MESSAGE LT: yyy.yyy

我需要,因为该主题将包含像机器系列的基本信息,例如'AWS/XYZ'。如何读取主题名称并从publish MQTT中读取'XYZ'?我需要得到主题名称在AWS lambda。我不能将串行机插入有效负载,但只能在发布主题的命名上。

共有1个答案

谯灿
2023-03-14

您需要向Gps类添加。topic属性。lambda收到的事件如下所示:

{
  "dt": "2020-02-26 18:03:30",
  "lt": "xxx.xxx",
  "ln": "yyy.yyy"
  "Topic: "your topic here"
}
 类似资料:
  • 我是新来的。 我已经开始将我的核心PHP项目转换为laravel 7。我被一些查询问题卡住了。 核心问题是: 我也把它改装成了拉威尔·布伊德。 但我对select列有异议。 请让我知道我错在哪里。 我最后的疑问是 错误是:未找到列:1054字段列表中的未知列'计数(DISTINCT(unitid))'

  • 我一直在考虑MQTT协议,但我不想让一个外部服务器运行MQTT代理,而且我找不到Win IoT的代理。Windows IOT Core是否存在MQTT代理?如果没有,你会推荐什么通信协议?

  • 最近我们的一个jvm崩溃了。生成了一个核心文件。我想看看那个文件,找出坠机的原因。但我无法分析核心。我用jmap分析了它。然后写下命令-: jmap-转储:格式=b,文件=heap.hprof核心22234 但是我一直在例外: 从可执行核心附加到核心22234,请等待...附加到核心文件的错误: Windbg错误: OpenDumpFile失败! 我的windows系统中有核心文件。我想在那里分析

  • 有没有一种方法可以轻松地将面向.NETCore2.0的类库转换为.NET标准? 如果我理解正确,如果有人想在针对不同.NET框架(例如.NET Framework,.NET Core,Xamarin等)的项目中最大限度地提高类库的可重用性,那么以.NET Standard为目标的更好主意 - 前提是所有必需的API都可以在将要定位的.NET Standard版本中提供。 这就是我想将类库从. NE

  • 这是.NET framework 4.8---->.NET core 5.0 我有一个个人的国际象棋引擎,我正在工作,昨天我决定从.NET framework切换到.NET Core。 在这个过程中我没有更改1行代码,完全相同的代码。 当我这样做的时候,我注意到损失了几个百分点,在2%到5%之间(目前为止) 这足以看出perft每秒平均有500,000到200,000步的差异(如果你不知道这是什么

  • apachebeam中的核心转换(Map、Filter、flatte)是否使用并行处理来处理数据元素,如果是,具体什么时候应该使用ParDo转换?