| 功能说明 | 函数说明 | 备注 |
|---|---|---|
| 文件上传 | smart_upload(csvfilepath) | |
| 获取数据 | get_dataset(id, param={}) | |
| 发送邮件 | dash_mail(标题, 内容, 邮件列表) | |
| 执行shell | run_bash(cmdStr) | |
| 执行datax | run_datax(‘DAG名/任务名’, para_dict) | |
| 执行sql | run_sql_file(‘DAG名/任务名’, db_connect=‘starrocks’, para_dict=None) | |
| 执行kettle | run_kettle(‘DAG名/任务名.ktr’, para_str=’’) | |
| 执行SP | run_sp(sp_name, sp_para=None, dev=’’, db_connect=‘oracle’) |
注:
- para_dict为字典格式参数