推送方案

数据推送主要用于将设施云实时数据（如告警、设备状态、设备属性等）通过配置推送规格推送到KAFKA服务端，对应伙伴应用去监听对应topic来获取这些实时数据。

图1 推送方案

• 伙伴在华为云上购买了KFAKA服务，用于伙伴订阅推送的数据。
• 通过不同topic进行不同项目数据逻辑隔离。
• 通过Kafka ACL进行Topic权限管理。

  设施云Kafka用户。

  • 用户名：root
  • 权限：发布

  伙伴Kafka用户

  • 用户名：sumg_zuolin
  • 用户名规则：{项目名}_{伙伴名}
  • 权限：订阅指定topic消息

  Topic定义

  格式定义：

  >由租户名、消息类型、应用名组成，中间用点分隔。

  >项目名：各项目名称，如musi，可以取项目实例名称。

  >消息类型：分三种类型event-up|meta-data|properties-report。

  >应用名：伙伴名称，如zuolin。

  >字符要求：小写，支持字母数字，中划线，点。

  

  1、如果是公有云环境，推荐伙伴还是去华为云上购买华为云的KAFKA，只需要购买一个通过不同的topic去区分就可以给不同的项目去对接使用。

  2、如果是伙伴使用自己搭建的KAFKA（云边场景），对应KAFKA服务端要配置为SASL_PLAINTEXT认证方式，而不能使用SASL_SSL认证方式。