FC 多云对象存储数据容灾

<?php

require 'vendor/autoload.php';

use OSS\OssClient;
use OSS\Core\OssException;
use Aws\S3\S3Client;
use Aws\Exception\AwsException;
use Aws\S3\MultipartUploader;
use Aws\Exception\MultipartUploadException;

$config = [
    'huawei' => [
        'credentials' => [
            'key'       => '3R9RMYDLWTSWUTL8SZ0C',                      // Secret ID
            'secret'    => 'iEgSGsHongfsxJjXFS4X5ixxPxR6TSeBxYYlfPNC',  // Secret Key
        ],
        'bucket'    => 'hongfs-backup-wc0dl2nipqz68tjr',                // 存储桶名称
        'endpoint'  => 'https://obs.cn-south-1.myhuaweicloud.com',      // Endpoint
        'region'    => 'cn-south-1',                                    // 地域
        'version'   => '2006-03-01',                                    // 版本号，固定
    ],
    'tencent' => [
        'credentials' => [
            'key'       => 'xx',
            'secret'    => 'xx',
        ],
        'bucket'    => 'hongfs-backup-xx-1252156936',
        'endpoint'  => 'https://cos.ap-guangzhou.myqcloud.com',
        'region'    => 'ap-guangzhou',
        'version'   => '2006-03-01',
    ],
];

function handler($event, $context) {
    global $config;

    // 获取事件信息
    $event = json_decode($event, true)['events'][0];

    // 实例化 OSS
    $oss = new OssClient(
        $context['credentials']['accessKeyId'],
        $context['credentials']['accessKeySecret'],
        'https://oss-' . $event['region'] . '-internal.aliyuncs.com',
        false,
        $context['credentials']['securityToken']
    );

    // 上传的文件 key (目录/文件名.后缀)
    $object_key = $event['oss']['object']['key'];

    // 本地临时存储路径
    $filepath = '/tmp/' . $context['requestId'] . '-' . basename($object_key);

    try {
        // 下载文件到临时存储
        $oss->getObject($event['oss']['bucket']['name'], $object_key, [
            OssClient::OSS_FILE_DOWNLOAD => $filepath,
        ]);
    } catch (OssException $e) {
        echo $e->getMessage() . "\n";
        return '0';
    }

    // 循环厂商
    foreach($config as $item) {
        // 将本地文件采用切片方式上传到对应厂商
        $uploader = new MultipartUploader(new S3Client($item), $filepath, [
            'bucket'    => $item['bucket'],
            'key'       => $object_key,
        ]);

        try {
            // 执行上传操作
            $uploader->upload();
        } catch (MultipartUploadException $e) {
            echo $e->getMessage() . "\n";
        }
    }

    // 删除本地文件释放空间
    unset($filepath);

    return '1';
}