DataWorks提供开放消息能力,您可以在DataWorks开放平台开启消息订阅功能,通过订阅DataWorks的事件消息,应用系统对接DataWorks,实时获取相关内容的状态变化。例如,您可以通过开放消息获取DataWorks中数据库表和调度任务的状态变更信息,实现个性化响应行为。

使用限制

  • 仅在华北2(北京)、华东1(杭州)、华南1(深圳)和华东2(上海)地域启动公测。
  • 仅支持DataWorks企业版用户参与公测活动,正式商业化方案及时间另行通知。

    企业版用户可以直接参与公测并试用开放消息能力,无需申请和支付相关费用。

  • 仅支持阿里云账号开启消息订阅功能,不支持RAM用户操作。
  • 公测期间,仅支持创建1个Topic、1个Consumer Group和1个用户。
    说明 关于Topic、Consumer Group及用户的详细介绍请参见名词解释

操作步骤

使用开放消息前,需要按照如下指导在DataWorks上先开启消息订阅功能并配置好消息队列Kafka版的相关配置信息,方便后续使用消息队列Kafka版开发消息订阅。

  1. 登录DataWorks控制台
  2. 在左侧导航栏,单击开放平台
  3. 选择开放消息,打开启动消息订阅开关,即可开启消息订阅服务。
    说明 开启消息订阅服务后,DataWorks将会把指定事件类型的消息推送到您创建的Topic中,若关闭启动消息订阅开关,则会停止所有Topic的消息推送。
  4. 单击新建Topic,填写Topic名称和描述,单击确定
    说明 该Topic主要描述消息的主题,用于消息分类。Topic名称一旦创建,无法修改。
  5. 在所创建的Topic右侧,单击订阅设置,在Topic订阅内容设置窗口,为当前Topic选择需要订阅的工作空间和事件类型。
    Topic订阅内容设置
    说明
    • 一个Topic最多可以订阅5个工作空间。
    • 目前,订阅事件类型仅支持任务变更事件、文件发布检查事件和表变更事件,不同地域支持的消息类型有所不同,具体请以产品界面为准(更多事件类型逐步丰富中,敬请期待)。
  6. 单击新建用户,在Topic下拉列表,选择需要订阅的Topic,填写Consumer Group名称、用户名、密码、描述信息,单击确定,即可创建一个用户。
    说明
    • Consumer表示从消息队列Kafka版接收消息的应用。
    • Consumer Group代表一组具有相同Group ID的Consumer。
    • 此处创建的用户及密码用于消息队列Kafka版的PLAIN机制的安全校验。
    • Consumer Group用户名一旦创建,无法修改。
    • 如果需要修改Consumer Group用户名,则需要删除该用户,重新创建即可。
    • 目前密码不支持修改,如需更改,可在用户列表区域进行重置即可。

后续步骤

现在您已经学习了如何开启消息订阅功能以及如何创建消息队列Kafka版的Topic、Consumer Group和用户等信息,请务必妥善保存这些信息,方便后续开发消息订阅。接下来,您将学习如何开发消息订阅,实现自由订阅DataWorks的事件消息。