本文介紹了TypeScript SDK的安裝方法、示例代碼以及如何使用TypeScript SDK發布事件。
SDK簡介
事件總線EventBridge的SDK分為管控API SDK和數據API SDK,示例代碼有所不同。
管控API SDK:對控制臺頁面進行操作使用的SDK。
數據API SDK:事件數據的通道,目前只有發送事件(PutEvents)屬于此類。
前提條件
您已完成以下操作:
環境準備
安裝Node.js 8.0或以上的版本。更多信息,請參見安裝Node.js。
執行命令
node -v
查看Node.js版本。執行以下命令全局安裝TypeScript。
npm install -g typescript
管控API SDK
安裝SDK
執行以下命令安裝TypeScript SDK。
npm install --save @alicloud/eventbridge20200401@1.0.1
SDK示例
您可以在OpenAPI門戶通過調用API接口,自動生成對應的SDK示例。具體操作,請參見如何自動生成SDK示例。
數據API SDK
安裝SDK
執行以下命令安裝TypeScript SDK。
npm install @alicloud/eventbridge -S
執行以下命令安裝打印端口。
npm install @alicloud/tea-console -S
SDK示例
數據API SDK目前只包含發布事件(PutEvents),如需使用TypeScript SDK發布一個或多個事件,請參考以下示例代碼。
import EventBridge, * as $EventBridge from '@alicloud/eventbridge';
import Util from '@alicloud/tea-util';
import Console from '@alicloud/tea-console';
import * as $tea from '@alicloud/tea-typescript';
export default class Client {
/**
* Create client初始化公共請求參數。
*/
static async createClient(): Promise<EventBridge> {
let config = new $EventBridge.Config({ });
SetAccessKeyId(os.Getenv("ALIBABA_CLOUD_ACCESS_KEY_ID")).
SetAccessKeySecret(os.Getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET")).
SetEndpoint("<endpoint>")
return new EventBridge(config);
}
/**
* PutEvents
*/
static async PutEvents(client: EventBridge): Promise<void> {
let event = new $EventBridge.CloudEvent({ });
event.datacontenttype = "application/json";
event.data = Util.toBytes("test");
event.id = "a5074581-7e74-4e4c-868f-47e7afdf8445";
event.source = "acs.oss";
event.specversion = "1.0";
event.type = "oss:ObjectCreated:PostObject";
event.time = "2020-08-24T13:54:05.965Asia/Shanghai";
event.subject = "1.0";
event.type = "acs:oss:cn-hangzhou:1234567:xls-papk/game_apk/123.jpg";
event.extensions = {
aliyuneventbusname: "demo-bus",
};
try {
let resp = await client.putEvents([
event
]);
Console.log("--------------------Publish event to the aliyun EventBus--------------------");
Console.log(Util.toJSONString($tea.toMap(resp)));
} catch (error) {
Console.log(error.message);
}
}
static async main(args: string[]): Promise<void> {
let client = await Client.createClient();
await Client.PutEvents(client);
}
}
Client.main(process.argv.slice(2));
文檔內容是否對您有幫助?