通过任务编排实现事件调度

操作步骤

本示例通过DMS任务编排实现event_click_archive事件。该事件的描述：希望从2020年12月1日开始，每天0点钟把user_click表中两天前的数据转储到click_history表（历史表）中并删除user_click表中的对应数据，user_click表中始终只保留当前日期前一天的数据。

该事件的SQL代码如下。

DELIMITER |

CREATE EVENT IF NOT EXISTS event_click_archive
ON SCHEDULE EVERY 1 DAY STARTS '2020-12-01 00:00.00'
ON COMPLETION PRESERVE
COMMENT '定期归档user_click表数据'
DO
  BEGIN
    INSERT INTO click_history SELECT * FROM user_click
      WHERE create_time < DATE_SUB(CURRENT_TIMESTAMP, INTERVAL 1 DAY);
    DELETE FROM user_click WHERE create_time < DATE_SUB(CURRENT_TIMESTAMP, INTERVAL 1 DAY);
  END |

DELIMITER ;

1. 登录新版DMS控制台。
2. 在页面顶部，选择全部功能 > 数据工厂 > 任务编排。
3. 在任务编排页面的自由编排任务区域，单击新建任务流。
   
4. 在新建任务流对话框，将任务流名称设置为df_archive_click，将描述设置为测试，单击确认。即会进入任务编排页面。
   
5. 在任务编排页面的左侧任务类型中，选择数据库运维 > 单实例SQL，并拖拽至页面中的空白区域。
   
6. 单击单实例SQL节点，在右侧面板中单击内容设置页签，配置以下信息。
   1. 从数据库列表中，选择目标实例。
   2. 输入以下建表语句。

      INSERT INTO click_history SELECT * FROM user_click
            WHERE create_time < DATE_SUB(CURRENT_TIMESTAMP, INTERVAL 1 DAY);
            
      DELETE FROM user_click WHERE create_time < DATE_SUB(CURRENT_TIMESTAMP, INTERVAL 1 DAY);

      说明 任务编排并不支持本地变量（Local Variable）。如果事件定义中使用了本地变量，那么在迁移至任务编排中的时候，需统一修改为用户自定义变量（User-Defined Variables）并用SET命令进行赋值。如下是一组示例。

      事件定义中的SQL：

      DECLARE n_total BIGINT DEFAULT 0;
      SELECT COUNT(*) INTO n_total FROM test_table;

      任务编排中的SQL：

      SET @n_total := (SELECT COUNT(*) FROM test_table);

   3. 完成以上配置后，单击保存按钮。
      
7. 单击任务流中画布的空白处，在右侧面板中单击调度配置页签，打开开启调度按钮，配置如下信息，并单击保存。

   该操作会设置：从2020年12月1日开始，每天0点自动按天调度（执行）该任务。

   至此，该任务流（df_archive_click）已经具备了与event_click_archive事件完全一致的调度行为，可以完全替代event_click_archive事件。此外，DMS任务编排还提供了多种MySQL事件所没有的功能，例如消息通知和运行状态的追踪。

   

   说明 任务流调度周期支持每月、每周、每天等多维度配置，您可以按需求选择调度周期，更多信息请参见开启调度配置。
8. 在右侧面板中单击基础属性页签，配置相关人员，并打开开启消息通知开关。
   

   说明 任务编排集成了消息通知功能，支持将任务调度状态（执行成功或执行失败）第一时间推送给目标用户，更多信息，请参见配置基础属性与消息通知管理。
9. 单击页面左上方的试运行按钮执行任务。