AnalyticDB 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 |
- 设置优先级调度
3.1.3.6及以上版本支持优先级调度。您可通过hint语法标识异步任务的优先级,默认优先级值为1,值越大表示优先级越高,会被系统优先调度。
mysql> /*+async_job_priority=10*/ submit job insert overwrite into test select * from test_external_table;
查询异步任务状态
- 语法
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';
- 说明
- 未调度起来的任务和已完成(失败或成功)的任务会被移除队列。
- 正在运行的任务会被终止,已导入的数据也会被回滚。
在文档使用中是否遇到以下问题
更多建议
匿名提交