添加 Amazon EventBridge 事件PutEvents - Amazon EventBridge
处理失败PutEvents使用Amazon CLI
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅中国的 Amazon Web Services 服务入门。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

添加 Amazon EventBridge 事件PutEvents

这些区域有：PutEvents操作发送多个事件在一次请求中添加到 EventBridge 中。有关更多信息，请参阅 。PutEvents中的Amazon EventBridge API 参考和事件推出中的Amazon CLI命令参考。

每个 PutEvents 请求可支持有限数目的条目。有关更多信息，请参阅Amazon EventBridge 配额。PutEvents 操作将尝试按请求的自然顺序处理所有条目。在呼叫后续PutEvents，EventBridge 将为每个事件指定一个唯一的 ID。

主题

以下示例 Java 代码将两个相同的事件发送到 EventBridge。

Amazon SDK for Java Version 2.x 
EventBridgeClient eventBridgeClient =
    EventBridgeClient.builder().build();

PutEventsRequestEntry requestEntry = PutEventsRequestEntry.builder()
    .resources("resource1", "resource2")
    .source("com.mycompany.myapp")
    .detailType("myDetailType")
    .detail("{ \"key1\": \"value1\", \"key2\": \"value2\" }")
    .build();

List <
PutEventsRequestEntry > requestEntries = new ArrayList <
PutEventsRequestEntry > ();
requestEntries.add(requestEntry);

PutEventsRequest eventsRequest = PutEventsRequest.builder()
    .entries(requestEntries)
    .build();

PutEventsResponse result = eventBridgeClient.putEvents(eventsRequest);

for (PutEventsResultEntry resultEntry: result.entries()) {
    if (resultEntry.eventId() != null) {
        System.out.println("Event Id: " + resultEntry.eventId());
    } else {
        System.out.println("PutEvents failed with Error Code: " + resultEntry.errorCode());
    }
}
Amazon SDK for Java Version 1.0 
EventBridgeClient eventBridgeClient =
    EventBridgeClient.builder().build();
    
PutEventsRequestEntry requestEntry = new PutEventsRequestEntry()
        .withTime(new Date())
        .withSource("com.mycompany.myapp")
        .withDetailType("myDetailType")
        .withResources("resource1", "resource2")
        .withDetail("{ \"key1\": \"value1\", \"key2\": \"value2\" }");

PutEventsRequest request = new PutEventsRequest()
        .withEntries(requestEntry, requestEntry);

PutEventsResult result = awsEventsClient.putEvents(request);

for (PutEventsResultEntry resultEntry : result.getEntries()) {
    if (resultEntry.getEventId() != null) {
        System.out.println("Event Id: " + resultEntry.getEventId());
    } else {
        System.out.println("Injection failed with Error Code: " + resultEntry.getErrorCode());
    }
}

运行此代码后，PutEvents结果包含响应条目的数组。响应数组中的每个条目按从请求和响应的开始到结束的顺序对应于请求数组中的一个条目。响应 Entries 数组包含的条目数量始终与请求数组相同。

处理失败PutEvents

默认情况下，如果请求中的单个条目失败，EventBridge 将继续处理请求中的其余条目。响应Entries数组可以包含成功条目和不成功条目。您必须删除不成功的条目并在后续调用中包括它们。

成功的结果条目包括Id值，不成功的结果条目包含ErrorCode和ErrorMessage有效值。ErrorCode描述了错误的类型。ErrorMessage提供有关错误的更多信息。以下示例具有针对PutEvents请求. 第二个条目不成功。 

{
    "FailedEntryCount": 1, 
    "Entries": [
        {
            "EventId": "11710aed-b79e-4468-a20b-bb3c0c3b4860"
        },
        {   "ErrorCode": "InternalFailure",
            "ErrorMessage": "Internal Service Failure"
        },
        {
            "EventId": "d804d26a-88db-4b66-9eaf-9a11c708ae82"
        }
    ]
}

您可以在后续中包含不成功的条目PutEvents请求. 首先，要了解请求中是否存在失败的条目，请检查FailedRecordCount中的参数PutEventsResult。如果它不是零，那么你可以添加每个Entry具有ErrorCode对于后续请求来说不为空。以下示例显示了一个故障处理程序。 

PutEventsRequestEntry requestEntry = new PutEventsRequestEntry()
        .withTime(new Date())
        .withSource("com.mycompany.myapp")
        .withDetailType("myDetailType")
        .withResources("resource1", "resource2")
        .withDetail("{ \"key1\": \"value1\", \"key2\": \"value2\" }");

List<PutEventsRequestEntry> putEventsRequestEntryList = new ArrayList<>();
for (int i = 0; i < 3; i++) {
    putEventsRequestEntryList.add(requestEntry);
}

PutEventsRequest putEventsRequest = new PutEventsRequest();
putEventsRequest.withEntries(putEventsRequestEntryList);
PutEventsResult putEventsResult = awsEventsClient.putEvents(putEventsRequest);

while (putEventsResult.getFailedEntryCount() > 0) {
    final List<PutEventsRequestEntry> failedEntriesList = new ArrayList<>();
    final List<PutEventsResultEntry> PutEventsResultEntryList = putEventsResult.getEntries();
    for (int i = 0; i < PutEventsResultEntryList.size(); i++) {
        final PutEventsRequestEntry putEventsRequestEntry = putEventsRequestEntryList.get(i);
        final PutEventsResultEntry putEventsResultEntry = PutEventsResultEntryList.get(i);
        if (putEventsResultEntry.getErrorCode() != null) {
            failedEntriesList.add(putEventsRequestEntry);
        }
    }
    putEventsRequestEntryList = failedEntriesList;
    putEventsRequest.setEntries(putEventsRequestEntryList);
    putEventsResult = awsEventsClient.putEvents(putEventsRequest);
    }

使用Amazon CLI

您可以将Amazon CLI将自定义事件发送到 EventBridge，以便处理它们。以下示例将一个自定义事件放入 EventBridge 中：

aws events put-events \
--entries '[{"Time": "2016-01-14T01:02:03Z", "Source": "com.mycompany.myapp", "Resources": ["resource1", "resource2"], "DetailType": "myDetailType", "Detail": "{ \"key1\": \"value1\", \"key2\": \"value2\" }"}]'

您还可以创建包含自定义事件的 JSON 文件。

[
  {
    "Time": "2016-01-14T01:02:03Z",
    "Source": "com.mycompany.myapp",
    "Resources": [
      "resource1",
      "resource2"
    ],
    "DetailType": "myDetailType",
    "Detail": "{ \"key1\": \"value1\", \"key2\": \"value2\" }"
  }
]

然后，要使用Amazon CLI读取该文件中的条目并发送事件，请在命令提示符下键入：

aws events put-events --entries file://entries.json