工作流操作 -奇异果体育app竞彩官网下载

private void createworkflow(bvwclient client) {
    client.createworkflow(createsimpleworkflowrequest("simple_workflow"));
    client.createworkflow(createcomplexworkflowrequest("complex_workflow"));
}
// 创建一个简单的工作流
private workflowcreaterequest createsimpleworkflowrequest(string workflowname) {
    // 创建开始节点(start stage)
    stageparammodel startstageparam = stageparammodel.of("{}");
    stagemodel startstage = stagemodel.of("start", startstageparam, stagetype.start);
    // 创建转码节点(transcoding stage)
    stageparammodel transcodingstageparam = stageparammodel.of(
            "{\"job\":{\"pipelinename\":\"test_transcoding\",\"source\":{},\"target\":{\"presetname\":"
                     "\"bvwtest\",\"targetbucket\":\"videoworks-source\"}},\"needdetectblackboard\":true,"
                     "\"adjustorientation\":\"all\"}");
    stagemodel transcodingstage = stagemodel.of("transcoding", transcodingstageparam,
                                                stagetype.transcoding);
    // 创建发布节点(publish stage)
    stageparammodel publishstageparam = stageparammodel.of("{}");
    stagemodel publishstage = stagemodel.of("publish", publishstageparam, stagetype.publish);
    // 设置节点
    map<string, stagemodel> stages = maps.newhashmap();
    stages.put(startstage.getname(), startstage);
    stages.put(transcodingstage.getname(), transcodingstage);
    stages.put(publishstage.getname(), publishstage);
    // 设置节点依赖关系
    map<string, list<string>> dependencies = maps.newhashmap();
    dependencies.put(startstage.getname(), lists.newarraylist(transcodingstage.getname());
    dependencies.put(transcodingstage.getname(), lists.newarraylist(publishstage.getname()));
    dependencies.put(publishstage.getname(), lists.newarraylist());
    // 构建workflowcreaterequest
    dagmodel dag =  dagmodel.of(stages, dependencies);
    return workflowcreaterequest.of(workflowname, dag);
}
// 创建一个复杂的工作流
private workflowcreaterequest createcomplexworkflowrequest(string workflowname) {
    // 创建开始节点(start stage)
    stageparammodel startstageparam = stageparammodel.of("{}");
    stagemodel startstage = stagemodel.of("start", startstageparam, stagetype.start);
    // 创建元信息提取节点(mediainfo stage)
    stageparammodel mediainfostageparam = stageparammodel.of("{}");
    stagemodel mediainfostage = stagemodel.of("mediainfo", mediainfostageparam, stagetype.mediainfo);
    // 创建黑边检测节点(blackborder stage)
    stageparammodel blackborderdetectstageparam = stageparammodel.of("{}");
    stagemodel blackborderdetectstage = stagemodel.of("blackborderdetect", blackborderdetectstageparam,
                                                      stagetype.black_border_detect);
    // 创建转码节点(transcoding stage)
    stageparammodel transcodingstageparam = stageparammodel.of(
            "{\"job\":{\"pipelinename\":\"test_transcoding\",\"source\":{},\"target\":{\"presetname\":"
                     "\"bvwtest\",\"targetbucket\":\"videoworks-source\"}},\"needdetectblackboard\":true,"
                     "\"adjustorientation\":\"all\"}");
    stagemodel transcodingstage = stagemodel.of("transcoding", transcodingstageparam,
                                                stagetype.transcoding);
    // 创建缩略图节点(thumbnail stage)
    stageparammodel thumbnailstageparam = stageparammodel.of(
            "{\"notificationname\":\"test\",\"job\":{\"pipelinename\":\"test_thumbnail\",\"target\":"
                     "{\"targetbucket\":\"videoworks-source\",\"format\":\"jpg\",\"sizingpolicy\":\"keep\"},"
                     "\"capture\":{\"mode\":\"auto\"}}}");
    stagemodel thumbnailstage = stagemodel.of("thumbnail", thumbnailstageparam, stagetype.thumbnail);
    // 创建发布节点(publish stage)
    stageparammodel publishstageparam = stageparammodel.of("{}");
    stagemodel publishstage = stagemodel.of("publish", publishstageparam, stagetype.publish);
    // 设置节点
    map<string, stagemodel> stages = maps.newhashmap();
    stages.put(startstage.getname(), startstage);
    stages.put(mediainfostage.getname(), mediainfostage);
    stages.put(blackborderdetectstage.getname(), blackborderdetectstage);
    stages.put(transcodingstage.getname(), transcodingstage);
    stages.put(thumbnailstage.getname(), thumbnailstage);
    stages.put(publishstage.getname(), publishstage);
    // 设置节点依赖关系
    map<string, list<string>> dependencies = maps.newhashmap();
    dependencies.put(startstage.getname(), lists.newarraylist(blackborderdetectstage.getname(),
                                                              mediainfostage.getname(),
                                                              thumbnailstage.getname()));
    dependencies.put(blackborderdetectstage.getname(), lists.newarraylist(transcodingstage.getname()));
    dependencies.put(transcodingstage.getname(), lists.newarraylist(publishstage.getname()));
    dependencies.put(mediainfostage.getname(), lists.newarraylist(publishstage.getname()));
    dependencies.put(thumbnailstage.getname(), lists.newarraylist(publishstage.getname()));
    dependencies.put(publishstage.getname(), lists.newarraylist());
    // 构建workflowcreaterequest
    dagmodel dag =  dagmodel.of(stages, dependencies);
    return workflowcreaterequest.of(workflowname, dag);
}

private void deleteworkflow(bvwclient client, string workflowname) {
    client.deleteworkflow(workflowname);
}

private void updateworkflow(bvwclient client) {
    client.updateworkflow(updateworkflowrequest("update_workflow"));
}
// 创建更新的工作流请求
private workflowupdaterequest updateworkflowrequest(string workflowname) {
    // 创建开始节点(start stage)
    stageparammodel startstageparam = stageparammodel.of("{}");
    stagemodel startstage = stagemodel.of("start", startstageparam, stagetype.start);
    // 创建转码节点(transcoding stage)
    stageparammodel transcodingstageparam = stageparammodel.of(
            "{\"job\":{\"pipelinename\":\"test_transcoding\",\"source\":{},\"target\":{\"presetname\":"
                     "\"bvwtest\",\"targetbucket\":\"videoworks-source\"}},\"needdetectblackboard\":true,"
                     "\"adjustorientation\":\"all\"}");
    stagemodel transcodingstage = stagemodel.of("transcoding", transcodingstageparam,
                                                stagetype.transcoding);
    // 创建发布节点(publish stage)
    stageparammodel publishstageparam = stageparammodel.of("{}");
    stagemodel publishstage = stagemodel.of("publish", publishstageparam, stagetype.publish);
    // 设置节点
    map<string, stagemodel> stages = maps.newhashmap();
    stages.put(startstage.getname(), startstage);
    stages.put(transcodingstage.getname(), transcodingstage);
    stages.put(publishstage.getname(), publishstage);
    // 设置节点依赖关系
    map<string, list<string>> dependencies = maps.newhashmap();
    dependencies.put(startstage.getname(), lists.newarraylist(transcodingstage.getname()));
    dependencies.put(transcodingstage.getname(), lists.newarraylist(publishstage.getname()));
    dependencies.put(publishstage.getname(), lists.<string>newarraylist());
    // 构建workflowcreaterequest
    dagmodel dag =  dagmodel.of(stages, dependencies);
    return workflowupdaterequest.of(workflowname, dag);
}

private void getworkflow(bvwclient client, string workflowname) {
    client.getworkflow(workflowname);
}

private void listworkflow(bvwclient client) {
    int pageno = 1;
    int pagesize = 10;
    string begin = "2019-06-30t16:00:00z";
    string end = "2019-07-30t16:00:00z";
    string workflownamefuzzy = "test";
    workflowlistrequest request = workflowlistrequest.of(pageno, pagesize, workflowstatus.normal,
                                                         workflownamefuzzy, begin, end);
    listbypageresponse<workflowlistresponse> response = client.listworkflow(request);
}

private void enableworkflow(bvwclient client, string workflowname) {
    client.enableworkflow(workflowname);
}

private void disableworkflow(bvwclient client, string workflowname) {
    client.disableworkflow(workflowname);
}