本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
添加亚马逊EventBridge活动PutEvents
这些区域有:PutEvents
动作发送多个事件到EventBridge在单一请求中。有关更多信息,请参阅 。PutEvents中的亚马逊EventBridgeAPI 参考和事件中的Amazon CLI命令参考.
每个 PutEvents
请求可支持有限数目的条目。有关更多信息,请参阅 Amazon EventBridge 配额。PutEvents
操作将尝试按请求的自然顺序处理所有条目。打电话后PutEvents
、EventBridge为每个事件分配唯一的 ID。
以下示例 Java 代码将两个相同的事件发送到EventBridge.
在您运行此代码之后,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