ListHubSpotObjects 2025.10.2.19¶
捆绑包¶
com.snowflake.openflow.runtime | runtime-hubspot-processors-nar
描述¶
从 HubSpot 提取指定对象类型的数据，并为每个列出的对象生成一个 FlowFile，并将相应的元数据作为 FlowFile 属性。对象类型必须是可搜索的，这意味着它支持访问 /search 端点。有关可搜索对象类型的更多信息，请参阅：https://developers.hubspot.com/docs/reference/api/crm/objects/objects#search (https://developers.hubspot.com/docs/reference/api/crm/objects/objects#search)")
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
HubSpot 服务 |
HubSpot 客户端服务。 |
对象类型 |
HubSpot 对象类型 |
之后更新 |
筛选在指定日期（格式：yyyy-MM-dd）之后更新的对象 |
状态管理¶
范围 |
描述 |
|---|---|
CLUSTER |
保持分页状态和上次同步时间戳，以便在重启后从最后一个已知位置继续检索数据，并仅提取更改的数据。 |
关系¶
名称 |
描述 |
|---|---|
failure |
HubSpot fail 关系 |
original |
输入 FlowFile 将路由到 original 关系。 |
retry |
HubSpot retry 关系。由于服务器超时或速率限制相关的错误而无法处理的 FlowFiles。FlowFiles 将路由至此处，应重新送入处理器以重试。 |
success |
HubSpot success 关系 |
写入属性¶
名称 |
描述 |
|---|---|
mime.type |
application/json |
statement.type |
对于这个处理器，始终是“UPSERT” |
hubspot.object.type |
此次提取的 HubSpot 对象类型 |
hubspot.object.id |
此次提取的 HubSpot 对象 ID |
hubspot.run.id |
本次运行开始的时间戳。如果没有，则从传入 FlowFile 时或当前时间开始获取 |
hubspot.is_last |
这是否是引入的最后一个分页对象 |
用例¶
此处理器通常与 GenerateFlowFile 处理器结合使用 |