1.5.3 集成小米Talos服务
优质
小牛编辑
126浏览
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数据,这个选项一旦选择,不可编辑修改。