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

管道管理

更新时间：
一键部署
提交缺陷
产品详情
相关技术圈
我的收藏

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

添加管道

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

import Console from '@alicloud/tea-console';
import OpenApi, * as $OpenApi from '@alicloud/openapi-client';
import Env from '@alicloud/darabonba-env';
import Util from '@alicloud/tea-util';
import mts20140618, * as $mts20140618 from '@alicloud/mts20140618';
import * as $tea from '@alicloud/tea-typescript';

/**
 * Node.js环境版本为8.x及以上。
 * 安装阿里云SDK  npm install @alicloud/pop-core --save
 * 安装Credentials工具。  npm install @alicloud/credentials
 * 安装MPS SDK npm install --save @alicloud/mts20140618
 * 
 */
 export default class Client {

    /** 初始化 Client */
    static async createClient(accessKeyId: string, accessKeySecret: string, regionId: string): Promise<mts20140618> {
        let config = new $OpenApi.Config({ });
        config.accessKeyId = accessKeyId;
        config.accessKeySecret = accessKeySecret;
        /** 接口服务地域 */
        config.regionId = "cn-shanghai";
        return new mts20140618(config);
    }

    static async main(args: string[]): Promise<void> {
        let client = await Client.createClient(Env.getEnv("ALIBABA_CLOUD_ACCESS_KEY_ID"), Env.getEnv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"), args[0]);

        let request = new $mts20140618.AddPipelineRequest({
            name: "test-pipeline",
            speed: "Standard",
        });
        let response = await client.addPipeline(request);
        Console.log(Util.toJSONString($tea.toMap(response)));
    }
}

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

搜索管道

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

import Console from '@alicloud/tea-console';
import OpenApi, * as $OpenApi from '@alicloud/openapi-client';
import Env from '@alicloud/darabonba-env';
import Util from '@alicloud/tea-util';
import mts20140618, * as $mts20140618 from '@alicloud/mts20140618';
import * as $tea from '@alicloud/tea-typescript';

/**
 * Node.js环境版本为8.x及以上。
 * 安装阿里云SDK  npm install @alicloud/pop-core --save
 * 安装Credentials工具。  npm install @alicloud/credentials
 * 安装MPS SDK npm install --save @alicloud/mts20140618
 * 
 */
 export default class Client {

    /** 初始化 Client */
    static async createClient(accessKeyId: string, accessKeySecret: string, regionId: string): Promise<mts20140618> {
        let config = new $OpenApi.Config({ });
        config.accessKeyId = accessKeyId;
        config.accessKeySecret = accessKeySecret;
        /** 接口服务地域 */
        config.regionId = "cn-shanghai";
        return new mts20140618(config);
    }

    static async main(args: string[]): Promise<void> {
        let client = await Client.createClient(Env.getEnv("ALIBABA_CLOUD_ACCESS_KEY_ID"), Env.getEnv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"), args[0]);

        let request = new $mts20140618.SearchPipelineRequest({
            state: "All",
        });
        let response = await client.searchPipeline(request);
        Console.log(Util.toJSONString($tea.toMap(response)));
    }
}

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

查询管道

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

import Console from '@alicloud/tea-console';
import OpenApi, * as $OpenApi from '@alicloud/openapi-client';
import Env from '@alicloud/darabonba-env';
import Util from '@alicloud/tea-util';
import mts20140618, * as $mts20140618 from '@alicloud/mts20140618';
import * as $tea from '@alicloud/tea-typescript';

/**
 * Node.js环境版本为8.x及以上。
 * 安装阿里云SDK  npm install @alicloud/pop-core --save
 * 安装Credentials工具。  npm install @alicloud/credentials
 * 安装MPS SDK npm install --save @alicloud/mts20140618
 * 
 */
 export default class Client {

    /** 初始化 Client */
    static async createClient(accessKeyId: string, accessKeySecret: string, regionId: string): Promise<mts20140618> {
        let config = new $OpenApi.Config({ });
        config.accessKeyId = accessKeyId;
        config.accessKeySecret = accessKeySecret;
        /** 接口服务地域 */
        config.regionId = "cn-shanghai";
        return new mts20140618(config);
    }

    static async main(args: string[]): Promise<void> {
        let client = await Client.createClient(Env.getEnv("ALIBABA_CLOUD_ACCESS_KEY_ID"), Env.getEnv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"), args[0]);

        let request = new $mts20140618.QueryPipelineListRequest({
            pipelineIds: "d1ce4d3e193f50f1fcd******,72dfa5e679ab4b9974c736*****",
        });
        let response = await client.queryPipelineList(request);
        Console.log(Util.toJSONString($tea.toMap(response)));
    }
}

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

更新管道

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

import Console from '@alicloud/tea-console';
import OpenApi, * as $OpenApi from '@alicloud/openapi-client';
import Env from '@alicloud/darabonba-env';
import Util from '@alicloud/tea-util';
import mts20140618, * as $mts20140618 from '@alicloud/mts20140618';
import * as $tea from '@alicloud/tea-typescript';

/**
 * Node.js环境版本为8.x及以上。
 * 安装阿里云SDK  npm install @alicloud/pop-core --save
 * 安装Credentials工具。  npm install @alicloud/credentials
 * 安装MPS SDK npm install --save @alicloud/mts20140618
 * 
 */
 export default class Client {

    /** 初始化 Client */
    static async createClient(accessKeyId: string, accessKeySecret: string, regionId: string): Promise<mts20140618> {
        let config = new $OpenApi.Config({ });
        config.accessKeyId = accessKeyId;
        config.accessKeySecret = accessKeySecret;
        /** 接口服务地域 */
        config.regionId = "cn-shanghai";
        return new mts20140618(config);
    }

    static async main(args: string[]): Promise<void> {
        let client = await Client.createClient(Env.getEnv("ALIBABA_CLOUD_ACCESS_KEY_ID"), Env.getEnv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"), args[0]);

        let request = new $mts20140618.UpdatePipelineRequest({
            pipelineId: "d1ce4d3efcb5193f50f1fcd****",
            name: "example-pipeline",
            state: "Paused",
          });
        let response = await client.updatePipeline(request);
        Console.log(Util.toJSONString($tea.toMap(response)));
    }
}

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

删除管道

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

import Console from '@alicloud/tea-console';
import OpenApi, * as $OpenApi from '@alicloud/openapi-client';
import Env from '@alicloud/darabonba-env';
import Util from '@alicloud/tea-util';
import mts20140618, * as $mts20140618 from '@alicloud/mts20140618';
import * as $tea from '@alicloud/tea-typescript';

/**
 * Node.js环境版本为8.x及以上。
 * 安装阿里云SDK  npm install @alicloud/pop-core --save
 * 安装Credentials工具。  npm install @alicloud/credentials
 * 安装MPS SDK npm install --save @alicloud/mts20140618
 * 
 */
 export default class Client {

    /** 初始化 Client */
    static async createClient(accessKeyId: string, accessKeySecret: string, regionId: string): Promise<mts20140618> {
        let config = new $OpenApi.Config({ });
        config.accessKeyId = accessKeyId;
        config.accessKeySecret = accessKeySecret;
        /** 接口服务地域 */
        config.regionId = "cn-shanghai";
        return new mts20140618(config);
    }

    static async main(args: string[]): Promise<void> {
        let client = await Client.createClient(Env.getEnv("ALIBABA_CLOUD_ACCESS_KEY_ID"), Env.getEnv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"), args[0]);

        let request = new $mts20140618.DeletePipelineRequest({
          pipelineId: "498ac94138d884ce46*****",
        });
        let response = await client.deletePipeline(request);
        Console.log(Util.toJSONString($tea.toMap(response)));
    }
}

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

相关文档

  • 本页导读 （1）
文档反馈