快速入门

新建业务流程

1. 登录DataWorks控制台。
2. 在左侧导航栏，单击工作空间列表。
3. 单击相应工作空间后的进入数据开发。
4. 单击左上角的图标，选中全部产品 > Stream Studio。
5. 在数据开发页面，鼠标悬停至，单击业务流程。
6. 在新建业务流程对话框中，输入业务名称和描述。
   注意 业务名称不能超过128个字符。
7. 单击新建。

新建实时计算任务

1. 右键单击新建的业务流程，选中新建任务。
2. 在新建节点对话框中，输入节点名称，节点类型和目标文件夹默认无需修改。
   注意 节点名称以字母开头，仅包含小写英文字母、数字和下划线（_）。
3. 单击提交，进入组件页面。
4. 在左侧导航栏，单击资源引用，勾选PUBLIC_COMMON。
   注意 仅独享模式的工作空间会显示资源引用界面。

   

   如果不勾选，后续使用用固定列切分组件时会收到如下提示。

编辑实时计算任务

1. 进入Stream Studio模块。
2. 在左侧导航栏，单击组件。
3. 在组件页面新增数据源。
   1. 拖拽数据源表 > DataHub至右侧面板。
   2. 单击DataHub组件，在页面右侧进行参数配置。

      参数	描述
      血缘表名（任务唯一）	对应建表语句中的表名，全局唯一，如果不填将使用真实表名填充。
      定义列	定义输出的列值。 单击自定义，单击选择字段对话框中的添加，输入名称和类型，单击确认，即可添加输出列。
      连接地址	对应SQL中with参数endPoint。
      accessId	对应SQL中with参数accessId。
      accessKey	对应SQL中with参数accessKey。
      项目名	对应SQL中with参数project。
      主题	对应SQL中with参数topic。
      开始时间	对应SQL中with参数startTime。
      读取最大重试次数	对应SQL中with参数maxRetryTimes，默认值为20。
      读取重试间隔	对应SQL中with参数retryIntervalMs，单位为毫秒，默认值为1,000。
      单次读取条数	对应SQL中with参数batchReadSize，默认值为10。
      单行字段条数检查策略	对应SQL中with参数lengthCheck，默认值为NONE。
      调试开关	对应SQL中with参数columnErrorDebug，是否打开调试开关。如果打开，会打印解析异常的日志，您可以在运维中心查看任务详情。

4. 数据处理。
   1. 在组件页面，拖拽一个固定列切分组件至面板中，进行字段切分。
      

      注意 仅独享模式的工作空间支持固定列切分组件。
   2. 连线DataHub组件至固定列切分组件。
   3. 单击DataHub组件，在页面右侧的参数配置中选择字段为tag。
      
   4. 修改列分隔符为（;）。
   5. 单击自定义，在选择字段对话框中，输入切分后字段的位置和名称，单击确认。
      
   6. 选择需要输出的字段：拖拽Select组件至右侧面板。
   7. 连接固定列切分组件与Select组件。单击Select节点，在面板中单击已选择0字段。
   8. 在选择字段对话框中，勾选id、m_type和weight字段，单击确认。
5. 输出数据结果（以输出上述处理结果至LogService为例）。
   1. 在组件页面，拖拽LogService组件至右侧面板。
   2. 连线Select组件至LogService组件。
   3. 单击LogService组件，在右侧配置组件的参数。

      参数	描述
      选择输出字段	单击已选择0字段，选择所有字段单击确认。
      连接地址	https://streamstudio-shanghai-test.cn-shanghai.log.aliyuncs.com。
      项目名	输入相应的项目名称。
      accessId	输入LogService账号的AccessKeyID，对应SQL中的with参数accessId。
      accessKey	输入LogService账号的AccessKeySecret，对应SQL中的with参数accessKey。
      日志名	输入相应的logStore名称。

6. 切换DAG模式与SQL模式。
   Stream Studio支持DAG模式编辑和SQL模式编辑流任务，两种模式对等，且支持互相转换。
   1. 单击右上角的切换为SQL模式，即可将DAG节点转换为对应的SQL。
   2. SQL视图如下所示，单击切换为DAG模式即可再次切换回DAG模式。
7. 设置执行计划。
   1. 单击右侧导航栏中的执行计划。
   2. 在请注意对话框中，单击确认。
   3. 单击保存执行计划。

发布实时计算任务

编辑好流任务之后即可进行任务发布。

1. 进入实时计算任务的编辑页面。
2. 单击保存图标后，单击发布。发布时会检查是否保存，如果没有保存则会提示您进行保存。
3. 在发布任务对话框中，输入版本备注，单击确定。
4. 发布成功后，单击右上角的运维，进入运维页面查看任务的状态并进行管理。

运维实时计算任务

进入运维页面后，您可以启动、下线和监控相应任务，也可以批量启动、暂停、恢复和停止任务。

• 启动任务。
  1. 单击相应任务后的启动。
  2. 在设置启动点位对话框中，选择启动点位。
  3. 任务启动后，单击任务名称即可查看是否运行成功及其详细信息。
• 停止和下线任务。

  单击相应任务后的停止，即可停止该任务的运行。

  任务停止运行后，单击下线，即可下线已停止运行的任务。