AI 助理
备案控制台
文档
输入文档关键字查找
首页 媒体处理 开发参考 SDK参考 Node.js SDK 管道管理

管道管理

更新时间：
产品详情
我的收藏

管道是任务的队列。当您提交异步任务后，任务会进入管道中进行排队，根据优先级和提交顺序依次被调度执行。本文提供了Node.js SDK V2.0管道相关功能的API调用示例，包含添加管道、更新管道、删除管道、查询管道。

添加管道

可以通过添加管道接口新增一个管道。

'use strict';


const Mts20140618 = require('@alicloud/mts20140618');
const OpenApi = require('@alicloud/openapi-client');
const Util = require('@alicloud/tea-util');
const Tea = require('@alicloud/tea-typescript');

class Client {

    /**
     * 使用AK&SK初始化账号Client
     * @return Client
     * @throws Exception
     */
    static createClient() {

        let config = new OpenApi.Config({
                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
                accessKeyId: process.env['ALIBABA_CLOUD_ACCESS_KEY_ID'],
                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
                accessKeySecret: process.env['ALIBABA_CLOUD_ACCESS_KEY_SECRET'],
    });

        config.endpoint = `mts.cn-qingdao.aliyuncs.com`;
        return new Mts20140618.default(config);
    }

    static async main(args) {
        let client = Client.createClient();
        let addPipelineRequest = new Mts20140618.AddPipelineRequest({
                //管道名称
                name: 'test-pipeline',
                //管道类型
                speed: 'Standard',
                //管道级别
                speedLevel: 1,
                //MNS通知配置
                notifyConfig: '{"Topic":"mts-topic-1"}',
                //角色
                role: 'AliyunMTSDefaultRole',
    });
        let runtime = new Util.RuntimeOptions({ });
        try {
            // 复制代码运行请自行打印 API 的返回值
            await client.addPipelineWithOptions(addPipelineRequest, runtime);
        } catch (error) {
            // 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
            // 错误 message
            console.log(error.message);
            // 诊断地址
            console.log(error.data["Recommend"]);
            Util.default.assertAsString(error.message);
        }
    }

}

exports.Client = Client;
Client.main(process.argv.slice(2));

搜索管道

可以通过搜索管道接口搜索管道信息。

'use strict';


const Mts20140618 = require('@alicloud/mts20140618');
const OpenApi = require('@alicloud/openapi-client');
const Util = require('@alicloud/tea-util');
const Tea = require('@alicloud/tea-typescript');

class Client {

    /**
     * 使用AK&SK初始化账号Client
     * @return Client
     * @throws Exception
     */
    static createClient() {

        let config = new OpenApi.Config({
                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
                accessKeyId: process.env['ALIBABA_CLOUD_ACCESS_KEY_ID'],
                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
                accessKeySecret: process.env['ALIBABA_CLOUD_ACCESS_KEY_SECRET'],
    });

        config.endpoint = `mts.cn-qingdao.aliyuncs.com`;
        return new Mts20140618.default(config);
    }

    static async main(args) {
        let client = Client.createClient();
        let searchPipelineRequest = new Mts20140618.SearchPipelineRequest({
                //需要搜索的管道状态
                state: 'Paused',
                //分页查询时设置的每页行数大小
                pageSize: 10,
                //当前页号
                pageNumber: 1,
    });
        let runtime = new Util.RuntimeOptions({ });
        try {
            // 复制代码运行请自行打印 API 的返回值
            await client.searchPipelineWithOptions(searchPipelineRequest, runtime);
        } catch (error) {
            // 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
            // 错误 message
            console.log(error.message);
            // 诊断地址
            console.log(error.data["Recommend"]);
            Util.default.assertAsString(error.message);
        }
    }

}

exports.Client = Client;
Client.main(process.argv.slice(2));

查询管道

可以通过pipelineId调用查询管道接口，查询管道信息。

'use strict';


const Mts20140618 = require('@alicloud/mts20140618');
const OpenApi = require('@alicloud/openapi-client');
const Util = require('@alicloud/tea-util');
const Tea = require('@alicloud/tea-typescript');

class Client {

    /**
     * 使用AK&SK初始化账号Client
     * @return Client
     * @throws Exception
     */
    static createClient() {

        let config = new OpenApi.Config({
                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
                accessKeyId: process.env['ALIBABA_CLOUD_ACCESS_KEY_ID'],
                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
                accessKeySecret: process.env['ALIBABA_CLOUD_ACCESS_KEY_SECRET'],
    });

        config.endpoint = `mts.cn-qingdao.aliyuncs.com`;
        return new Mts20140618.default(config);
    }

    static async main(args) {
        let client = Client.createClient();
        let queryPipelineListRequest = new Mts20140618.QueryPipelineListRequest({
                //需要查询的管道ID列表
                pipelineIds: 'd1ce4d3efcb549419193f50f1fcd****,72dfa5e679ab4be9a3ed9974c736****',
    });
        let runtime = new Util.RuntimeOptions({ });
        try {
            // 复制代码运行请自行打印 API 的返回值
            await client.queryPipelineListWithOptions(queryPipelineListRequest, runtime);
        } catch (error) {
            // 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
            // 错误 message
            console.log(error.message);
            // 诊断地址
            console.log(error.data["Recommend"]);
            Util.default.assertAsString(error.message);
        }
    }

}

exports.Client = Client;
Client.main(process.argv.slice(2));

更新管道

可以通过更新管道接口，更新管道信息，包括更新管道名称，状态。管道的状态包括Active、Paused。

'use strict';


const Mts20140618 = require('@alicloud/mts20140618');
const OpenApi = require('@alicloud/openapi-client');
const Util = require('@alicloud/tea-util');
const Tea = require('@alicloud/tea-typescript');

class Client {

    /**
     * 使用AK&SK初始化账号Client
     * @return Client
     * @throws Exception
     */
    static createClient() {

        let config = new OpenApi.Config({
                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
                accessKeyId: process.env['ALIBABA_CLOUD_ACCESS_KEY_ID'],
                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
                accessKeySecret: process.env['ALIBABA_CLOUD_ACCESS_KEY_SECRET'],
    });

        config.endpoint = `mts.cn-qingdao.aliyuncs.com`;
        return new Mts20140618.default(config);
    }

    static async main(args) {
        let client = Client.createClient();
        let updatePipelineRequest = new Mts20140618.UpdatePipelineRequest({
                //需要更新的管道ID
                pipelineId: 'd1ce4d3efcb549419193f50f1fcd****',
                //修改后的管道名称
                name: 'example-pipeline-****',
                //修改后的管道状态
                state: 'Paused',
                //阿里云消息服务配置
                notifyConfig: '{"Topic":"example-topic-****"}',
                //当前RAM用户关联的角色
                role: 'AliyunMTSDefaultRole',
    });
        let runtime = new Util.RuntimeOptions({ });
        try {
            // 复制代码运行请自行打印 API 的返回值
            await client.updatePipelineWithOptions(updatePipelineRequest, runtime);
        } catch (error) {
            // 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
            // 错误 message
            console.log(error.message);
            // 诊断地址
            console.log(error.data["Recommend"]);
            Util.default.assertAsString(error.message);
        }
    }

}

exports.Client = Client;
Client.main(process.argv.slice(2));

删除管道

可以通过删除管道接口删除管道。

'use strict';


const Mts20140618 = require('@alicloud/mts20140618');
const OpenApi = require('@alicloud/openapi-client');
const Util = require('@alicloud/tea-util');
const Tea = require('@alicloud/tea-typescript');

class Client {

    /**
     * 使用AK&SK初始化账号Client
     * @return Client
     * @throws Exception
     */
    static createClient() {

        let config = new OpenApi.Config({
                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
                accessKeyId: process.env['ALIBABA_CLOUD_ACCESS_KEY_ID'],
                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
                accessKeySecret: process.env['ALIBABA_CLOUD_ACCESS_KEY_SECRET'],
    });

        config.endpoint = `mts.cn-qingdao.aliyuncs.com`;
        return new Mts20140618.default(config);
    }

    static async main(args) {
        let client = Client.createClient();
        let deletePipelineRequest = new Mts20140618.DeletePipelineRequest({
                //需要删除的管道ID
                pipelineId: 'd1ce4d3efcb549419193f50f1fcd****',
    });
        let runtime = new Util.RuntimeOptions({ });
        try {
            // 复制代码运行请自行打印 API 的返回值
            await client.deletePipelineWithOptions(deletePipelineRequest, runtime);
        } catch (error) {
            // 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
            // 错误 message
            console.log(error.message);
            // 诊断地址
            console.log(error.data["Recommend"]);
            Util.default.assertAsString(error.message);
        }
    }

}

exports.Client = Client;
Client.main(process.argv.slice(2));

相关文档

上一篇：创建HLS标准加密工作流下一篇：查询媒体-使用OSS文件地址
文档推荐