如何用ExportTableToPointInTimeRequest等待导出完成后执行后续操作

ExportTableToPointInTime 是异步接口，调用成功仅代表导出任务提交完成，不代表数据已经导出到S3。你需要通过轮询导出任务状态的方式，等任务进入终态后再执行后续Glue作业逻辑。

实现逻辑 #

• 从触发导出的返回结果中提取唯一的导出任务ARN，作为后续查询任务状态的标识
• 周期性调用DescribeExport接口查询任务状态，根据状态判断是继续等待、执行后续流程还是抛出异常
• 配置合理的轮询间隔和超时时间，避免API限流或者无限等待

任务状态说明 #

• IN_PROGRESS：任务执行中，继续等待
• COMPLETED：导出成功，S3数据已就绪，可以执行后续流程
• FAILED/CANCELLED：任务异常终止，直接中断流程抛出错误

完整代码示例 #

// 原有导出触发逻辑
ExportTableToPointInTimeRequest exportTableToPointInTimeRequest = new ExportTableToPointInTimeRequest()
        .withTableArn(tableArn)
        .withS3Bucket(s3Bucket)
        .withExportFormat(ExportFormat.DYNAMODB_JSON)
        .withS3Prefix(s3Prefix);
ExportTableToPointInTimeResult exportTableToPointInTimeResult =
        dynamoDB.exportTableToPointInTime(exportTableToPointInTimeRequest);

// 新增：等待导出完成逻辑
String exportArn = exportTableToPointInTimeResult.getExportDescription().getExportArn();
// 可根据实际表大小调整参数：轮询间隔20秒，最大超时2小时
long pollIntervalMs = 20 * 1000;
long timeoutMs = 2 * 60 * 60 * 1000;
long startTime = System.currentTimeMillis();

while (true) {
    // 超时校验
    if (System.currentTimeMillis() - startTime > timeoutMs) {
        throw new RuntimeException("DynamoDB导出任务超时，任务ARN：" + exportArn);
    }

    // 查询当前任务状态
    DescribeExportRequest describeReq = new DescribeExportRequest().withExportArn(exportArn);
    DescribeExportResult describeRes = dynamoDB.describeExport(describeReq);
    ExportStatus status = describeRes.getExportDescription().getExportStatus();

    if (ExportStatus.COMPLETED.equals(status)) {
        // 导出完成，跳出循环执行后续逻辑
        break;
    }
    if (ExportStatus.FAILED.equals(status) || ExportStatus.CANCELLED.equals(status)) {
        String failMsg = describeRes.getExportDescription().getFailureMessage();
        throw new RuntimeException("DynamoDB导出任务失败，状态：" + status + "，失败原因：" + failMsg);
    }

    // 任务执行中，等待间隔后重试
    try {
        Thread.sleep(pollIntervalMs);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
        throw new RuntimeException("等待导出过程中线程被中断", e);
    }
}

// 后续Glue作业等处理逻辑写在这里

注意事项 #

轮询间隔建议不低于10秒，避免触发DynamoDB API的请求限流。如果你的代码运行在Lambda等有执行时长限制的无服务器环境，大表导出可能超过函数最大超时时间，这种场景建议改用工作流服务编排任务，不要在单个函数内做长轮询。如果是运行在EC2、ECS等长运行环境，上述代码可以直接使用。

内容的提问来源于stack exchange，提问作者Achintya Kumar