Question

当您的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数据，这个选项一旦选择，不可编辑修改。