CloudEvents信息格式规范说明

事件源（这里指的是KS3）发布事件到KCF需要按照CloudEvents规范。关于CloudEvents规范的更多信息，请参见CloudEvents 1.0。

以下是事件源发布到云函数KCF的示例事件。

{
  "id": "45ef4dewdwe1-7c35-447a-bd93-fab****",
    "source": "kcs:ks3",
    "type": "ks3:ObjectCreated:PutObject",
    "specversion": "1.0",
    "datacontenttype": "application/json",
    "subject": "/cc",
    "extensions": {
        "region": "BEIJING",
        "eventversion": "1.0",
        "userid": "73400852",
        "accountid": "73404680"
    },
    "data": {
        "request": {
            "sourceIPAddress": "127.0.0.1"
        },
        "response": {
            "requestId": "daab11b695ea4c4ea7a1a71ce36d1100"
        },
        "ks3": {
            "bucket": {
                "name": "kcf-pj",
                "ownerid": "73404680"
            },
            "object": {
                "internalurl": "evt-jinyw.ks3-cn-beijing-internal.ksyuncs.com/ssssss.jpg",
                "etag": "etag-xxxxxxx",
                "objectsize": "1024",
                "url": "evt-jinyw.ks3-cn-beijing.ksyuncs.com/ssssss.jpg",
                "key": "ssssss.jpg"
            }
        }
    }
}

CloudEvents参数说明

事件函数中涉及的CloudEvents参数说明如下所示：

extensions结构体

 {
        "region": "BEIJING",
        "eventversion": "1.0",
        "accountid": "7320"
 }

data结构体

{
        "request": {
            "sourceIPAddress": "127.0.0.1"
        },
        "response": {
            "requestId": "daab11b695ea4c4ea7a1a71ce36d1100"
        },
        "ks3": {
            "bucket": {
                "name": "kcf",
                "ownerid": "7340"
            },
            "object": {
                "internalurl": "evt.ks3-cn-beijing-internal.ksyuncs.com/ssssss.jpg",
                "etag": "etag-xxxxxxx",
                "objectsize": "1024",
                "url": "evt.ks3-cn-beijing.ksyuncs.com/ssssss.jpg",
                "key": "ssssss.jpg"
            }
        }
}

Cloudevents对象模型示例

Java

import lombok.Data;

@Data
public class Ks3CloudEventData {
    RequestData request;
    ResponseData response;
    Ks3Data ks3;

}

@Data
public class Ks3Data {
    Bucket bucket;
    DataObject object;
}

@Data
public class Bucket {
    String name;
    String ownerid;
}

@Data
public class DataObject {
    String internalurl;
    String etag;
    String objectsize;
    String url;
    String key;
}


@Data
public class RequestData {
    String sourceIPAddress;
}

@Data
public class ResponseData {
    String requestId;
}