# 新建SQL作业 - CreateFlinkSqlJob #### 功能介绍 该API用于创建Flink SQL作业。 #### 调试 您可以在[API Explorer](https://apiexplorer.developer.huaweicloud.com/apiexplorer/doc?product=DLI&api=CreateFlinkSqlJob)中调试该接口。 #### 授权信息 账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。 - 如果使用角色与策略授权，具体权限要求请参见[权限及授权项说明](https://support.huaweicloud.com/api-dli/dli_02_0375.html)。 - 如果使用身份策略授权，需具备如下身份策略权限。 | 授权项 Action | 访问级别 Access Level | 资源类型（\*为必须） Resource Type (\*: required) | 条件键 Condition Key | 别名 Alias | 依赖的授权项 Dependencies | |:---|:---|:---|:---|:---|:---| | dli:jobs:create | write | jobs \* | - | - | - | | dli:jobs:create | write | - | - [g:RequestTag/\](https://support.huaweicloud.com/usermanual-iam5/iam_01_1287.html) - [g:TagKeys](https://support.huaweicloud.com/usermanual-iam5/iam_01_1287.html) | - | - | #### URI - URI格式 POST /v1.0/{project_id}/streaming/sql-jobs - 参数说明 表1URI参数说明 | 参数名称 | 是否必选 | 参数类型 | 说明 | |:---|:---|:---|:---| | project_id | 是 | String | 项目编号，用于资源隔离。获取方式请参考[获取项目ID](https://support.huaweicloud.com/api-dli/dli_02_0183.html)。 | #### 请求消息 表2请求参数说明 | 参数名称 | 是否必选 | 参数类型 | 说明 | |:---|:---|:---|:---| | name | 是 | String | 作业名称。长度限制：1-57个字符。 | | desc | 否 | String | 作业描述。长度限制：0-512个字符。 | | template_id | 否 | Integer | 模板ID。 如果"template_id"和"sql_body"都不为空，优先选择"sql_body"的内容；如果"template_id"不为空，"sql_body"为空，选择"template_id"的内容填充"sql_body"。 | | queue_name | 否 | String | 队列名称。长度限制：0-128个字符。 | | sql_body | 否 | String | Stream SQL语句，至少包含source, query, sink三个部分。长度限制：1024\*1024个字符。 | | run_mode | 否 | String | 作业运行模式： - shared_cluster：共享。 - exclusive_cluster：独享。 - edge_node：边缘节点。 默认值为"shared_cluster"。 | | cu_number | 否 | Integer | 用户为作业选择的CU数。默认值为"2"。 CU数量为DLI的计算单元数量和管理单元数量总和，CU也是DLI的计费单位，1CU=1核4G。当前配置的CU数量为运行作业时所需的CU数，不能超过其绑定队列的CU数量。管理单元参数设置详见：manager_cu_number。 | | parallel_number | 否 | Integer | 用户设置的作业并行数目。默认值为"1"。 并行数是指同时运行Flink SQL作业的最大任务数。适度增加并行数会提高作业整体算力，但也须考虑线程增多带来的切换开销。最大并行数不能大于计算单元（CU数量-管理单元）的4倍。 管理单元参数设置详见：manager_cu_number。 | | checkpoint_enabled | 否 | Boolean | 是否开启作业自动快照功能。 - 开启：true - 关闭：false - 默认：false | | checkpoint_mode | 否 | String | 快照模式，两种可选： - 1：表示exactly_once，数据只被消费一次。 - 2：表示at_least_once，数据至少被消费一次。 默认值为1。 | | checkpoint_interval | 否 | Integer | 快照时间间隔。单位为秒，默认值为"10"。 | | obs_bucket | 否 | String | 当"checkpoint_enabled"为"true"时，该参数是用户授权保存快照的OBS桶名。 当"log_enabled" 为"true"时，该参数是用户授权保存作业日志的OBS桶名。 | | log_enabled | 否 | Boolean | 是否开启作业的日志上传到用户的OBS功能。默认为"false"。 | | smn_topic | 否 | String | 当作业异常时，向该SMN主题推送告警信息。 | | restart_when_exception | 否 | Boolean | 是否开启作业异常自动重启。默认为"false"。 | | idle_state_retention | 否 | Integer | 空闲状态保留时间。单位为秒，默认值为"3600"。 | | job_type | 否 | String | 作业类型：flink_sql_job、flink_opensource_sql_job。 默认值："flink_opensource_sql_job"。 - "run_mode"为"exclusive_cluster"时，作业类型须为"flink_sql_job"或"flink_opensource_sql_job"。 - "run_mode""为"shared_cluster"时作业类型必须为"flink_sql_job"。 | | edge_group_ids | 否 | Array of Strings | 边缘计算组ID列表, 多个ID以逗号分隔。 | | dirty_data_strategy | 否 | String | 作业脏数据策略。 - "2:obsDir"：保存，obsDir表示脏数据存储路径。 - "1"：抛出异常。 - "0"：忽略。 默认值为"0"。 | | udf_jar_url | 否 | String | 用户已上传到DLI资源管理系统的资源包名，用户sql作业的udf jar包通过该参数传入。 Flink1.15及以上版本在创建作业时仅支持配置OBS中的程序包，不支持读取DLI程序包。 | | manager_cu_number | 否 | Integer | 用户为作业选择的管理单元（jobmanager）CU数量，默认值为"1"。 | | tm_cus | 否 | Integer | 每个taskmanager的CU数，默认值为"1"。 | | tm_slot_num | 否 | Integer | 每个taskmanager的slot数，默认值为"(parallel_number\*tm_cus)/(cu_number-manager_cu_number)"。 | | resume_checkpoint | 否 | Boolean | 异常重启是否从checkpoint恢复。 | | resume_max_num | 否 | Integer | 异常重试最大次数，单位：次/小时。取值范围：-1或大于0。默认值为"-1"，表示无限次数。 | | tags | 否 | Array of Objects | Flink SQL作业的标签。具体请参考[表3]。 | | runtime_config | 否 | String | Flink作业运行时自定义优化参数。 | | flink_version | 否 | String | Flink版本。 | | execution_agency_urn | 否 | String | 授权给DLI的委托名。Flink1.15版本时支持配置该参数。 | | resource_config_version | 否 | String | 资源配置版本。可选值 "v1" ,"v2".默认为"v1"。 v2版本对比于v1模版不支持设置CU数量，支持直接设置Job Manager Memory和Task Manager Memory。 v1：适用于Flink 1.12、Flink 1.15 V2：适用于Flink 1.15、Flink 1.17 优先推荐使用V2版本的参数设置。 | | resource_config | 否 | Object | Flink 作业的资源配置。 具体参数说明请参考[表4]。 资源配置版本 为 "v2"时，配置生效，资源配置版本 为 "v1"时，配置无效。 | | flink_log_config | 否 | String | **参数解释：** 配置日志和状态。Flink 1.15及以上版本支持配置该参数。 **取值范围：** 包括：root_logger_level、loggers_level_of_class 日志级别取值说明请参考[表7]。 - **root_logger_level** 日志级别用于区分日志信息的重要性和紧急程度。根日志级别是全局的日志级别设置，它为整个应用程序提供了一个默认的日志级别。 当没有为特定的日志记录器或类设置日志级别时，根日志级别将被使用。例如，如果根日志级别设置为INFO，那么所有未单独设置级别的日志记录器都将输出INFO及以上级别的日志。 从低到高，日志级别的优先级通常为：TRACE\