首页 | 新闻 | 新品 | 文库 | 方案 | 视频 | 下载 | 商城 | 开发板 | 数据中心 | 座谈新版 | 培训 | 工具 | 博客 | 论坛 | 百科 | GEC | 活动 | 主题月 | 电子展
返回列表 回复 发帖

基于 Kubernetes 集群的 Serverless 在 IoT 中的应用(8)

基于 Kubernetes 集群的 Serverless 在 IoT 中的应用(8)

将两个 Action 链接在上两个小节,我们已经创建了两个 Action,一个将执行输入格式标准化(formatInput),另一个                Action(enricher)将根据被调用时传入的 topic 值,从数据库 MongoDB 执行查找,以显示资产的相关信息。
OpenWhisk 允许将多个 Action 链接在一起,也就是说前一个 Action 的输出是后一个 Action                的输入。此功能称为序列,序列定义了执行 Action 的顺序;同时,序列也是一种 Action。
我们创建一个名为 iotServerlessSequence 的新序列 Action,该操作首先首先调用                formatInputAction,然后使用输出作为 richher Action 的输入参数。
图 29. 创建序列
接下来,我们更新之前创建的 iotServerlessRule,让它调用 iotServerlessSequence 序列操作,而不是直接调用                formatInput 操作:
图 30. 更新 rule
然后,我们触发 Trigger(传入的参数是 Topic 和经纬度数据):
图 31. 触发                    trigger
我们从输出结果获取到了 ID:6581c0968dfa49db81c0968dfa79db5c。
接下来,我们用刚获取到的 ID 来查询 activationId:
图 32. 查询                    activationId
查看 log 部分的 activationId,得到 1567ea66c3ff4099a7ea66c3ffb099a8。
图 33. 查询 log
用上一步获取到的 activationId,查看最终调用执行结果:
图 34. 查询执行结果
从结果中,我们可以看到资产的信息、其地理围栏信息、资产的图片等。这达到了我们预想的结果。
返回列表