Streaming SQL作业配置

步骤一：创建Streaming SQL作业

1. 通过主账号登录阿里云 E-MapReduce 控制台，进入集群列表页面。
2. 单击上方的数据开发页签，进入项目列表页面。
3. 单击对应项目右侧的工作流设计，然后在左侧导航栏中单击作业编辑。
4. 在作业编辑页面左侧，右键单击作业所属的文件夹并选择新建作业。
   说明 通过右键单击文件夹，您还可以进行创建子文件夹、重命名文件夹和删除文件夹操作。
5. 在弹出的新建作业对话框中，输入作业名称和作业描述，并从作业类型列表中选择Streaming SQL。
   
   
6. 单击确定，完成Streaming SQL的作业创建。
   作业创建完成后，自动进入该作业，您可根据实际需要配置作业的代码。

步骤二：配置作业的Streaming SQL语句

在E-MapReduce后台，Streaming SQL作业的提交方式是streaming-sql -f {SQL_SCRIPT}，其中SQL_SCRIPT中保存的即是Streaming SQL作业的代码，即Streaming SQL语句。

创建作业完成后，在作业内容文本框中输入Streaming SQL语句。

Streaming SQL语句示例：

--- 创建SLS数据表 
CREATE TABLE IF NOT EXISTS ${slsTableName} 
   USING loghub 
   OPTIONS ( 
        sls.project = '${logProjectName}', 
        sls.store = '${logStoreName}', 
        access.key.id = '${accessKeyId}', 
        access.key.secret = '${accessKeySecret}', 
        endpoint = '${endpoint}'
   ); 
--- 将数据导入HDFS 
INSERT INTO 
    ${hdfsTableName} 
SELECT 
    col1, col2 
FROM  ${slsTableName} 
WHERE ${condition}

步骤三：配置依赖库和失败策略

依赖库：Streaming SQL作业需要依赖一些数据源相关的库文件。E-MapReduce将这些库以依赖库的形式发布在调度服务的仓库中，在创建作业时需要指定使用哪个版本的依赖库。

失败策略：当前语句执行失败时的执行策略。

1. 完成作业代码配置后，单击右上方的作业设置，然后选择流任务设置。
2. 在流任务设置页面配置作业的依赖库和失败策略。

   区域	配置项	说明
   失败处理策略	当前语句执行失败时	当前语句执行失败时，支持如下策略： 继续执行下一条语句：如果查询语句执行失败， 继续执行下一条语句。 终止当前作业：如果查询语句执行失败， 终止当前作业。
   依赖库	库列表	您只需设置相应的依赖库版本，例如sharedlibs:streamingsql:datasources-bundle:1.7.0。

3. 单击保存，Streaming SQL作业配置即定义完成。