本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。
使用发布 AWS Lambda 函数的 SDK 指标 AWS SDK for Java 2.x
由于 Lambda 函数的执行时间通常为毫秒到几分钟，因此发送指标时出现的任何延迟（如发生这种情况）都有丢失CloudWatchMetricPublisher数据的风险。
EmfMetricLoggingPublisher通过立即将指标写成CloudWatch 嵌入式指标格式 (EMF) 的结构化日志条目，提供了一种更合适的方法。 EmfMetricLoggingPublisher适用于与 Amazon L CloudWatch ogs 内置集成的执行环境，例如 AWS Lambda 和亚马逊弹性容器服务。
设置
在使用启用和使用指标之前EmfMetricLoggingPublisher，请先完成以下步骤。
步骤 1：添加所需的依赖关系
将项目依赖项（例如，在您的 pom.xml 或 build.gradle 文件中）配置为使用 适用于 Java 的 AWS SDK版本 2.30.3 或更高版本。
在项目的依赖项中包含带有版本2.30.3号或更高版本号的 emf-metric-logging-publisher artifactID。
例如：
<project> <dependencyManagement> <dependencies> <dependency> <groupId>software.amazon.awssdk</groupId> <artifactId>bom</artifactId> <version>2.30.11</version> <!-- Navigate the link to see the latest version. --> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <dependencies> <dependency> <groupId>software.amazon.awssdk</groupId> <artifactId>emf-metric-logging-publisher</artifactId> </dependency> </dependencies> </project>
步骤 2：配置所需权限
为指标发布者使用的 IAM 身份启用logs:PutLogEvents权限，以允许适用于 Java 的 SDK 写入 EMF 格式的日志。
步骤 3：设置日志
为确保正确收集指标，请将您的日志配置为输出到INFO级别或更低级别的控制台（例如DEBUG）。在你的log4j2.xml文件中：
<Loggers> <Root level="WARN"> <AppenderRef ref="ConsoleAppender"/> </Root> <Logger name="software.amazon.awssdk.metrics.publishers.emf.EmfMetricLoggingPublisher" level="INFO" /> </Loggers>
有关如何设置log4j2.xml文件的更多信息，请参阅本指南中的日志主题。
配置和使用 EmfMetricLoggingPublisher
以下 Lambda 函数类首先创建和配置EmfMetricLoggingPublisher实例，然后将其与亚马逊 DynamoDB 服务客户端一起使用：
public class GameIdHandler implements RequestHandler<Map<String, String>, String> { private final EmfMetricLoggingPublisher emfPublisher; private final DynamoDbClient dynamoDb; public GameIdHandler() { // Build the publisher. this.emfPublisher = EmfMetricLoggingPublisher.builder() .namespace("namespace") .dimensions(CoreMetric.SERVICE_ID, CoreMetric.OPERATION_NAME) .build(); // Add the publisher to the client. this.dynamoDb = DynamoDbClient.builder() .overrideConfiguration(c -> c.addMetricPublisher(emfPublisher)) .region(Region.of(System.getenv("AWS_REGION"))) .build(); } @Override public String handleRequest(Map<String, String> event, Context context) { Map<String, AttributeValue> gameItem = new HashMap<>(); gameItem.put("gameId", AttributeValue.builder().s(event.get("id")).build()); PutItemRequest putItemRequest = PutItemRequest.builder() .tableName("games") .item(gameItem) .build(); dynamoDb.putItem(putItemRequest); return "Request handled"; } }
当 DynamoDB 客户端执行putItem该方法时，它会自动以 EMF 格式将指标发布到日志 CloudWatch 流。
例如，如果您将以下事件发送到 GameHandler Lambda 函数，且日志配置如前所示：
{ "id": "23456" }
在函数处理事件后，您会发现两个日志事件，它们与以下示例类似。第二个事件中的 JSON 对象包含 DynamoDB PutItem 操作的 Java SDK 指标数据。
当 CloudWatch 收到 EMF 格式的日志事件时，它会自动解析结构化的 JSON 以提取指标数据。 CloudWatch 然后创建相应的指标，同时将原始日志条目存储在 CloudWatch 日志中。
2025-07-11 15:58:30 [main] INFO org.example.GameIdHandler:39 - Received map: {id=23456} 2025-07-11 15:58:34 [main] INFO software.amazon.awssdk.metrics.publishers.emf.EmfMetricLoggingPublisher:43 - { "_aws": { "Timestamp": 1752249513975, "LogGroupName": "/aws/lambda/GameId", "CloudWatchMetrics": [ { "Namespace": "namespace", "Dimensions": [ [ "OperationName", "ServiceId" ] ], "Metrics": [ { "Name": "AvailableConcurrency" }, { "Name": "PendingConcurrencyAcquires" }, { "Name": "ServiceCallDuration", "Unit": "Milliseconds" }, { "Name": "EndpointResolveDuration", "Unit": "Milliseconds" }, { "Name": "MaxConcurrency" }, { "Name": "BackoffDelayDuration", "Unit": "Milliseconds" }, { "Name": "MarshallingDuration", "Unit": "Milliseconds" }, { "Name": "LeasedConcurrency" }, { "Name": "SigningDuration", "Unit": "Milliseconds" }, { "Name": "ConcurrencyAcquireDuration", "Unit": "Milliseconds" }, { "Name": "ApiCallSuccessful" }, { "Name": "RetryCount" }, { "Name": "UnmarshallingDuration", "Unit": "Milliseconds" }, { "Name": "ApiCallDuration", "Unit": "Milliseconds" }, { "Name": "CredentialsFetchDuration", "Unit": "Milliseconds" } ] } ] }, "AvailableConcurrency": 0, "PendingConcurrencyAcquires": 0, "OperationName": "PutItem", "ServiceCallDuration": 1339, "EndpointResolveDuration": 81, "MaxConcurrency": 50, "BackoffDelayDuration": 0, "ServiceId": "DynamoDB", "MarshallingDuration": 181, "LeasedConcurrency": 1, "SigningDuration": 184, "ConcurrencyAcquireDuration": 83, "ApiCallSuccessful": 1, "RetryCount": 0, "UnmarshallingDuration": 85, "ApiCallDuration": 1880, "CredentialsFetchDuration": 138 }
的 API 文档EmfMetricLoggingPublisher.Builder显示了您可以使用的配置选项。
您也可以为单个请求启用 EMF 指标日志记录，如所 CloudWatchMetricPublisher示。
后续步骤：对于长时间运行的应用程序，请参阅从长时间运行的应用程序发布 SDK 指标以发布 CloudWatch基于基础的指标。
