如何定义到 InfluxDB 的 Apache Camel 路由

Question

我想使用 Apache Camel 将数据发送到 InfluxDB。我处于这样一个初学者的水平，我什至无法理解骆驼的文档。我正在努力在 spring 配置 XML 的 <route> 标记中究竟需要写什么。 In the documentation 它说：

• URI 格式：influxdb://beanName?[options]
• 使用 URI 语法配置 InfluxDB 端点：influxdb:connectionBean

我如何使用这些信息？您能否提供一个更具指导性的示例，说明 config.xml 的外观以及如何在代码中调用它？

谢谢

Answer 1

我认为您需要配置一个 spring boot InfluxDb 类实例，然后按照文档中的说明使用 beanName 引用它。

这可以使用 spring boot 自动配置来创建：

• https://docs.spring.io/spring-boot/docs/current/reference/html/boot-features-nosql.html#boot-features-connecting-to-influxdb
• https://docs.spring.io/spring-boot/docs/current/api/org/springframework/boot/autoconfigure/influx/InfluxDbAutoConfiguration.html

根据Spring AnnotationNameGenerator，默认名称（来自 yml 自动配置的 bean）应该只是 influxDB。我们还可以查看the bean definition code 并确认它正在创建一个InfluxDB 类实例。

那么然后在camel中配置influxdb://influxDB。

---

除了自动配置这个替代方案也应该可以工作（未经测试 - source）：

@Configuration
public class AppConfig {
    @Bean(name = "myInflux")
    public InfluxDb influxClient{
        return InfluxDBFactory.connect(databaseURL, userName, password);
    }
}

然后在camel中配置influxdb://myInflux。