PublishGCPubSub 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-gcp-nar
描述¶
将传入 FlowFile 的内容发布到已配置的 Google Cloud PubSub 主题。该处理器支持动态属性。如果存在任何动态属性，它们将以“attributes”的形式与消息一起发送。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
GCP 凭据提供商服务 |
用于获取 Google Cloud Platform 凭据的控制器服务。 |
输入批大小 |
每次处理器调用的最大 FlowFiles 处理次数 |
最大消息大小 |
Google PubSub 消息的最大大小（以字节为单位）。默认为 1 MB（1048576 字节） |
消息衍生策略 |
用于将传入 FlowFile 发布到 Google Cloud PubSub 端点。 |
记录读取器 |
用于传入 FlowFiles 的记录读取器 |
记录写入器 |
用于在将数据发送到 GCPubSub 之前对数据进行序列化的记录写入器 |
api-endpoint |
以 [host:port] 的形式替换 gRPC 端点 |
gcp-batch-bytes |
发布请求将根据此批处理字节阈值属性和批处理大小阈值属性触发，以先满足的条件为准。 |
gcp-project-id |
Google Cloud 项目 ID |
gcp-pubsub-publish-batch-delay |
表示用于批处理的延迟阈值。经过这段时间（从添加的第一个元素开始统计）后，元素将批量打包并发送。此值不应设置得太高，通常以毫秒为单位。否则，调用可能永远无法完成。 |
gcp-pubsub-publish-batch-size |
表示云服务应批量捆绑在一起的消息数量。如果未设置且留空，则一批只使用一条消息 |
gcp-pubsub-topic |
Google Cloud PubSub 主题的名称 |
proxy-configuration-service |
指定代理配置控制器服务来代理网络请求。 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果 Google Cloud Pub/Sub 操作失败，则将 FlowFiles 路由到此关系。 |
retry |
如果 Google Cloud Pub/Sub 操作失败，则将 FlowFiles 路由到此关系，但再次尝试该操作可能会成功。 |
success |
Google Cloud Pub/Sub 操作成功后，将 FlowFiles 路由到此关系。 |
写入属性¶
名称 |
描述 |
|---|---|
gcp.pubsub.messageId |
发布到已配置的 Google Cloud PubSub 主题的 pubsub 消息的 ID |
gcp.pubsub.count.records |
发布到已配置的 Google Cloud PubSub 主题的 pubsub 消息的数量 |
gcp.pubsub.topic |
消息发布到的 Google Cloud PubSub 主题的名称 |