1.5.3 集成小米Talos服务

优质
小牛编辑
127浏览
2023-12-01

当您的Talos队列中有消息传递时,函数计算能够根据您创建的TalosTrigger获取相关消息,触发对应函数的执行。

目前函数计算同时支持新版及旧版Talos,在Java运行环境中可以使用。

在设置TalosTrigger前,请对group: CIf76b0600-24e9-42c4-acf3-d491fbd9fd71​ 授予 TOPIC_READ_AND_MESSAGE_FULL_CONTROL 权限。

在您的函数中event结构为:

```
{
     "partitionKey":"faas",
     "offset":238873,
     "timestap":1544600509284,
     "body": {
         ....
         ....
     }
 }
```

其中body字段为Talos中传递的消息,partitionKey为消息在Talos队列中的partitionKey,offset为消息在Talos队列中整个partition的第几条,您可以结合这两个字段有序的处理消息。 其中,函数计算的组件会对用户的talos中的数据做base64编码的处理,用户在读取数据的时候,需要对event中的body字段做base64解码,才可以正确解析数据。

也可以在创建TalosTrigger的时候,选择支持batch处理,并选择batch大小,这时在您的函数中event结构为:

```
{
  "size": <length of the records>
  "records": [{
     "partitionKey":"faas",
     "offset":238873,
     "timestap":1544600509284,
     "body": {
         ....
         ....
     },
     {
        "partitionKey":"faas",
        "offset":238874,
        "timestap":1544600509285,
        "body": {
            ....
            ....
     }]
   }
 }
```

其中,size表示这个batch中数据的条数,records是真正的batch数据。

还可以在创建talostrigger的时候,选择从开始位置还是最新位置开始读取talos数据,这个选项一旦选择,不可编辑修改。