AnalyticDB for MySQL中支持通过异步方式提交数据导入导出任务。

异步提交任务

  • 语法
    submit job insert overwrite into xxx select ...

    执行上述命令后,将返回一个job_id。

  • 示例
    mysql> submit job insert overwrite into test select * from test_external_table;
    +---------------------------------------+
    | job_id                               |
    +---------------------------------------+
    | 2017112122202917203100908203303000715 |

查询异步任务状态

  • 语法
    show job status where job=‘job_id’
  • 示例
    mysql> show job status where job='2017112122202917203100908203303000715';
    +---------------------------------------+-------------+---------+----------+-----------------------+-----------------------+--------------------------------------+
    | job_id                              | schema_name | status  | fail_msg | create_time           | update_time           | definition                           |
    +---------------------------------------+-------------+---------+----------+-----------------------+-----------------------+--------------------------------------+
    | 2017112122202917203100908203303000715 | test    | RUNNING | NULL     | 2017-11-21 22:20:31.0 | 2017-11-21 22:20:40.0 |  insert into test select * from test |
  • 任务状态说明
    • INIT:任务进入队列
    • RUNNING:后台开始执行任务
    • FINISH/FAILED:任务成功或失败

终止任务

  • 语法
    cancel job 'job_id'
  • 示例
    mysql> cancel job '2017112122202917203100908203303000715';
  • 说明
    • 未调度起来的任务和已完成(失败或成功)的任务会被移除队列。
    • 正在运行的任务会被终止,已导入的数据也会被回滚。