开启工作流消息通知,媒体工作流开始执行和完成执行时,会向指定的队列或主题发送消息通知。

操作步骤

  1. 根据实际需要创建队列或主题通知。具体操作请参见设置转码消息通知
    说明 目前媒体工作流触发执行的作业,忽略转码管道上绑定的消息机制,以创建工作流时实际绑定的主题通知(消息队列)为准。
  2. 创建工作流,其中输入节点参数需按下表设置,其余节点具体操作请参见创建工作流
    参数 描述
    输入Bucket 选择输入路径后自动显示。
    输入路径 待处理文件的输入路径。
    转码管道 选择在上一步中已经绑定的转码管道。
    消息通知 单击开启消息通知。
    消息类型 需要接收的消息类型。根据您管道绑定的消息类型选择。
    队列(通知)名称 选择对应的队列(主题通知)。

消息格式

媒体工作流消息通知的消息体是JSON格式,详细的字段名称、类型、描述请参见新增媒体中媒体工作流消息部分。

结构的层次定义如下:
  • 开始

    活动基本属性活动类型Start

  • 结构
    • 顶层

      JSON对象。定义:{当前活动的基本属性,工作流执行对象}

      • 当前活动的基本属性

        当前活动的基本属性不是一个独立的对象,是直接属于顶层的键值属性,可以参考下面的示例。定义:{工作流执行ID,活动名字活动类型,活动状态,错误信息}

      • 工作流执行详情对象

        JSON对象。定义:{工作流执行ID,媒体工作流ID,媒体工作流名字,媒体ID,输入文件,工作流执行类型,活动对象数组,创建时间}

    • 活动对象数组

      JSON数组,包含执行到当前状态的所有活动。例如:开始消息中只有一个Start活动对象,完成消息则包含所有活动对象。定义:[活动对象1,活动对象2…]

      • 活动对象1

        JSON对象。定义:{活动名字,活动类型,作业ID,活动状态,开始时间,结束时间,错误信息}

      • 活动对象2

        结构同活动对象1

  • 完成

    活动基本属性活动类型Report

  • 示例
    {      
          "RunId": "8f8aba5a62ab4127ae2add18da20****",
          "Name": "Act-4",
          "Type": "Report",
          "State": "Success",
          "MediaWorkflowExecution": {
            "Name": "ConcurrentSuccess",
            "RunId": "8f8aba5a62ab4127ae2add18da20****",
            "Input": {
                "InputFile": {
                    "Bucket": "exampleBucket****",
                    "Location": "oss-test", 
                   "Object": "mediaWorkflow/ConcurrentSuccess/01.wmv",
               }
            },
            "State": "Success",
            "MediaId": "2be491ab4cb6499cd0befe5fcf0c****",
            "ActivityList": 
    [            
    {
                    "RunId": "8f8aba5a62ab4127ae2add18da20****",
                    "Name": "Act-1",
                    "Type": "Start",
                    "State": "Success",
                    "StartTime": "2016-03-15T02: 53: 41Z",
                    "EndTime": "2016-03-15T02: 53: 41Z",
                },
                {                
                    "RunId": "8f8aba5a62ab4127ae2add18da20****",
                    "Name": "Act-2",
                    "Type": "Transcode",
                    "JobId": "f34b6d1429dd491faa7a6c1c8f90****",
                    "State": "Success",
                    "StartTime": "2016-03-15T02: 53: 43Z",
                    "EndTime": "2016-03-15T02: 53: 47Z",
                },
                {                
                    "RunId": "8f8aba5a62ab4127ae2add18da20****",
                    "Name": "Act-3",
                    "Type": "Snapshot",
                    "JobId": "c14150be33304825a5d67cd5364c****",
                    "State": "Success",
                    "StartTime": "2016-03-15T02: 53: 44Z",                
                    "EndTime": "2016-03-15T02: 53: 45Z",
                },
                {                
                    "RunId": "8f8aba5a62ab4127ae2add18da20****",
                    "Name": "Act-4",
                    "Type": "Report",
                    "State": "Success",
                    "StartTime": "2016-03-15T02: 53: 49Z",
                    "EndTime": "2016-03-15T02: 53: 49Z", 
               }
            ],
            "CreationTime": "2016-03-15T02: 53: 39Z",
          }
      }