Apache Camel集成AWS S3文件读取与日志配置指南

import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.main.Main;
import org.apache.camel.impl.DefaultCamelContext;

public class Example {

  public static void main(String[] args) throws Exception {
    var camelContext = new DefaultCamelContext(); // 初始化Camel上下文

    camelContext.addRoutes(new MainRoute()); // 添加自定义路由
    camelContext.start(); // 启动Camel上下文，开始处理路由
    Thread.sleep(10_000); // 保持主线程运行一段时间，以便路由可以处理消息
    camelContext.stop(); // 停止Camel上下文
  }
}

public class MainRoute extends RouteBuilder {

  @Override
  public void configure() {
    // 构建S3 URI，指定存储桶、文件前缀、认证方式和处理行为
    var s3Url = String.format(
        "aws2-s3://mybucket.com?" // 替换为您的S3存储桶名称
            + "prefix=etl/hello.csv&" // 指定要读取的文件路径或前缀
            + "useDefaultCredentialsProvider=true&" // 使用默认凭证提供者（例如IAM角色或环境变量）
            + "deleteAfterRead=false&" // 读取后不删除S3对象
            + "maxMessagesPerPoll=1"); // 每次轮询最多处理一条消息

    System.out.println("Route configuration started."); // 路由配置开始的标志

    // 定义Camel路由：从S3读取 -> 解组为CSV -> 记录日志
    from(s3Url)
        .unmarshal().csv() // 将文件内容解组为CSV格式
        .log("Received S3 CSV content: ${body}") // 记录解组后的内容
        .end();

    System.out.println("Route configuration finished."); // 路由配置结束的标志
  }
}

<dependencies>
    <!-- Apache Camel Core 和 AWS S3 组件依赖 -->
    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-core</artifactId>
        <version>3.19.0</version> <!-- 替换为您的Camel版本 -->
    </dependency>
    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-aws2-s3</artifactId>
        <version>3.19.0</version> <!-- 替换为您的Camel版本 -->
    </dependency>
    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-csv</artifactId>
        <version>3.19.0</version> <!-- 替换为您的Camel版本 -->
    </dependency>

    <!-- 强制添加日志实现：Log4j2 -->
    <dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId>log4j-api</artifactId>
        <version>${log4j2.version}</version> <!-- 定义log4j2.version属性，例如 2.17.2 -->
    </dependency>
    <dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId>log4j-core</artifactId>
        <version>${log4j2.version}</version>
    </dependency>
    <!-- SLF4J到Log4j2的适配器，确保所有SLF4J日志请求都能通过Log4j2处理 -->
    <dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId>log4j-slf4j-impl</artifactId>
        <version>${log4j2.version}</version>
    </dependency>
</dependencies>

<properties>
    <log4j2.version>2.17.2</log4j2.version> <!-- 推荐使用最新稳定版本 -->
</properties>