本文介紹了PHP SDK的安裝方法、示例代碼以及如何使用PHP SDK發布事件。
SDK簡介
事件總線EventBridge的SDK分為管控API SDK和數據API SDK,示例代碼有所不同。
管控API SDK:對控制臺頁面進行操作使用的SDK。
數據API SDK:事件數據的通道,目前只有發送事件(PutEvents)屬于此類。
前提條件
您已完成以下操作:
環境準備
環境要求
安裝PHP 5.6及以上版本。更多信息,請參見安裝PHP。
安裝Composer。更多信息,請參見安裝Composer。
查看語言版本
執行命令
php -v
查看PHP語言版本。
管控API SDK
安裝SDK
執行以下命令安裝PHP SDK。
composer require alibabacloud/eventbridge-20200401 1.0.0
SDK示例
您可以在OpenAPI門戶通過調用API接口,自動生成對應的SDK示例。具體操作,請參見如何自動生成SDK示例。
數據API SDK
安裝SDK
執行以下命令安裝PHP SDK。
composer require alibabacloud/eventbridge
執行以下命令安裝打印端口。
composer require alibabacloud/tea-console
SDK示例
數據API SDK目前只包含發布事件(PutEvents),如需使用PHP SDK發布一個或多個事件,請參考以下示例代碼。
<?php
namespace Alibabacloud\Sample;
use AlibabaCloud\SDK\EventBridge\Eventbridge;
use AlibabaCloud\SDK\EventBridge\Models\CloudEvent;
use AlibabaCloud\SDK\EventBridge\Models\Config;
use AlibabaCloud\Tea\Console\Console;
use AlibabaCloud\Tea\Exception\TeaError;
use AlibabaCloud\Tea\Utils\Utils;
use Exception;
class Client
{
/**
* Create client初始化公共請求參數。
*
* @return Eventbridge
*/
public static function createClient()
{
$config = new Config([]);
SetAccessKeyId(os.Getenv("ALIBABA_CLOUD_ACCESS_KEY_ID")).
SetAccessKeySecret(os.Getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET")).
SetEndpoint("<endpoint>")
return new Eventbridge($config);
}
/**
* PutEvents
*
* @param Eventbridge $client
*
* @return void
*/
public static function PutEvents($client)
{
$event = new CloudEvent([]);
$event->datacontenttype = 'application/json';
$event->data = Utils::toBytes('test');
$event->id = 'a5074581-7e74-4e4c-868f-47e7afdf****';
$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 {
$resp = $client->putEvents([
$event,
]);
Console::log('--------------------Publish event to the aliyun EventBus--------------------');
Console::log(Utils::toJSONString($resp->toMap()));
} catch (Exception $error) {
if (!($error instanceof TeaError)) {
$error = new TeaError([], $error->getMessage(), $error->getCode(), $error);
}
Console::log($error->message);
}
}
/**
* @param string[] $args
*
* @return void
*/
public static function main($args)
{
$client = self::createClient();
self::PutEvents($client);
}
}
require '../vendor/autoload.php';
Client::main([]);
文檔內容是否對您有幫助?