ConsumeGCPubSub
描述:
消费来自已配置Google Cloud PubSub的订阅消息。如果设置了“批大小”，则在单个请求中将拉取配置指定的消息数量，否则只拉取一条消息。
标签:
google, google-cloud, gcp, message, pubsub, consume, 消息, 消费
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 并且 参数还支持 表达式语言.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| 项目ID | 谷歌云项目ID | ||
| GCP凭据提供者服务 | 控制器服务API: GCPCredentialsService 实现: GCPCredentialsControllerService | 用于获取谷歌云平台凭据的控制器服务。 | |
| 订阅 | 谷歌云Pub/Sub的订阅名称 支持表达式语言 (仅支持变量) | ||
| 分批数量 | 15 | 指定云服务在一次批处理时应该打包的消息数量。如果没有设置，则在批处理中只打包一条消息。 |
连线:
| 名字 | 描述 |
|---|---|
| success | 成功执行谷歌云Pub/Sub操作后，流文件将路由到此连线。 |
读取属性:
未提供。
写入属性:
| 名字 | 描述 |
|---|---|
| gcp.pubsub.ackId | 已消费的谷歌云Pub/Sub消息的确认Id。 |
| gcp.pubsub.messageSize | 已消费的谷歌云Pub/Sub消息的序列化大小。 |
| gcp.pubsub.attributesCount | 已消费的PubSub消息拥有的属性数量（如果有的话）。 |
| gcp.pubsub.publishTime | 消息发布时的时间戳。 |
| Dynamic Attributes | 除了列出来的属性外，如果谷歌云发布服务器客户机在发送消息时填加了任何属性，该组件可能会写入0个或多个属性。 |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件禁止提供输入流。
系统资源考量:
未提供。