如何定义到InfluxDB的Apache Camel路由

WolfiG:

我想使用Apache Camel将数据发送到InfluxDB。我处于这样的初学者水平,以至于我什至都不了解骆驼的文档。我正在努力<route>在spring配置XML 标记中确切写些什么。在文档中说:

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

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

谢谢

本杰明·彼得(Benjamin Peter):

我认为您需要配置一个Spring Boot InfluxDb类实例,然后使用beanName按照文档中的说明进行引用

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

根据Spring AnnotationNameGenerator的名称,默认名称(来自yml自动配置的Bean)应该简单地为influxDB我们还可以查看bean定义代码,并确认它正在创建一个InfluxDB类实例。

因此,然后influxdb://influxDB在骆驼中进行配置


除了自动配置之外,此替代方法也应起作用(未测试- ):

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

然后influxdb://myInflux在骆驼中进行配置

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

Apache Camel-路由交易

Apache Camel 超时同步路由

如何定义“来自SOAP Web服务”的Apache Camel路由?

没有“ to”端点的Apache Camel路由

Spring Boot Apache Camel路由测试

Apache Camel路由未调用Processor

根据标签值路由消息-Apache Camel

为什么Apache Camel文件到sftp路由失败

Apache Camel http到http路由(可能吗?)

如何测试从目录中读取的 Camel 路由?

如何在Apache Camel> = 3中配置路由跟踪?

如何使Apache Camel在“直接”路由的末尾删除文件?

Apache Camel FTP-如何手动启动路由

如何找到路由的所有端点(Apache Camel,Java)

如何使用camel-quarkus-jdbc定义路由?

如何使用Apache Camel在集群环境中从SFTP到JMS的文件路由中丰富消息?

Apache Camel路由往返于Apache Kafka的中断异常

Apache Camel路由中的Spring Boot属性用法

处理期间删除文件时,Apache Camel路由挂起

Apache Camel 路由和 Spring boot:应用程序启动

单元测试 Apache-Camel JmsReplyTo 路由流

使用try catch时Apache Camel路由结束

在Apache Camel路由中使用动态logName

没有连接缓存的Apache Camel HTTP路由

Apache Camel-在路由到ActiveMQ期间,除String以外的所有标头均丢失

从Apache Camel路由返回值到Spring Boot控制器

如何从处理器内部的Apache Camel中的路由获取响应并在处理器内部调用该路由?

如何从一个路由到另一个路由获取标头-Camel JavaDsl

如何使用Apache Camel路由从文件中获取JSON对象并将其映射到Java类?