With Bean API[1]， you can write a customer Bean to use the Session API to send the data into IoTDB. Just a quick question, are you using Karaf (OSGi) this time? If so, you may need to provide a wrapped OSGi IoTDB client jar for it.
[1]https://camel.apache.org/manual/latest/parameter-binding-annotations.html Willem Jiang Twitter: willemjiang Weibo: 姜宁willem On Tue, Mar 3, 2020 at 9:35 PM Robinet, Etienne <[email protected]> wrote: > > Hi, > sadly I am pretty new at using camel and never worked with NoSQL DB but I > found this: > https://rterp.wordpress.com/2014/07/25/writing-to-a-nosql-db-using-camel/ > > Also, here is a blueprint I used with Oracle DB: > <?xml version="1.0" encoding="UTF-8"?> > <blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"; > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; > xmlns:cm=" > http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0"; > xsi:schemaLocation=" > http://www.osgi.org/xmlns/blueprint/v1.0.0 > https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd > http://camel.apache.org/schema/blueprint > http://camel.apache.org/schema/blueprint/camel-blueprint.xsd > http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0 > http://aries.apache.org/schemas/blueprint-cm/blueprint-cm-1.1.0.xsd";> > > > <camelContext id="TestContext" xmlns=" > http://camel.apache.org/schema/blueprint";> > > <route id="Route1"> > > <from uri="file://c:/test/in?delete=true"/> > <setBody><simple>Route1 :: ${body}</simple></setBody> > <to uri="sql:insert into test1_t(text) > values(:#${body})?dataSource=my-db"/> > </route> > > </camelContext> > > > <!-- The container provides a DataSource service connected to the database > --> > <reference id="my-db" interface="javax.sql.DataSource" filter="( > osgi.jndi.service.name=testDB)"/> > > > </blueprint> > > Le mar. 3 mars 2020 à 14:09, Xiangdong Huang <[email protected]> a écrit : > > > Hi Etienne, > > > > Can you share an example for integration Camel with some other DB (NoSQL is > > better)? > > It will be helpful to let us evaluate how to integrate with IoTDB. > > > > Best, > > ---------------------------------- > > Xiangdong Huang > > School of Software, Tsinghua University > > > > 黄向东 > > 清华大学 软件学院 > > > > > > Jialin Qiao <[email protected]> 于2020年3月3日周二 下午9:04写道： > > > > > Hi, > > > > > > If you only need a java api, the Session API is enough and better than > > > JDBC. > > > > > > There is an example about Session API: > > > > > > > > https://github.com/apache/incubator-iotdb/blob/master/example/session/src/main/java/org/apache/iotdb/SessionExample.java > > > > > > I'm not familiar with Camel, but when integrating with rocketmq or kafka, > > > the consumer could use Session API to write data into IoTDB. > > > > > > Thanks, > > > -- > > > Jialin Qiao > > > School of Software, Tsinghua University > > > > > > 乔嘉林 > > > 清华大学 软件学院 > > > > > > > -----原始邮件----- > > > > 发件人: "Robinet, Etienne" <[email protected]> > > > > 发送时间: 2020-03-03 20:55:43 (星期二) > > > > 收件人: [email protected] > > > > 抄送: > > > > 主题: Re: Prepared Statements/ Commit > > > > > > > > Hi, > > > > Can I use this session API in combination with camel? > > > > > > > > Le mar. 3 mars 2020 à 13:54, Jialin Qiao <[email protected]> > > a > > > > écrit : > > > > > > > > > Hi, > > > > > > > > > > PreparedStatement is not supported now. Instead, you could use > > Session > > > > > API, which also avoids the sql parser. > > > > > > > > > > Thanks, > > > > > -- > > > > > Jialin Qiao > > > > > School of Software, Tsinghua University > > > > > > > > > > 乔嘉林 > > > > > 清华大学 软件学院 > > > > > > > > > > > -----原始邮件----- > > > > > > 发件人: "Etienne Robinet" <[email protected]> > > > > > > 发送时间: 2020-03-03 20:35:56 (星期二) > > > > > > 收件人: [email protected] > > > > > > 抄送: > > > > > > 主题: Prepared Statements/ Commit > > > > > > > > > > > > Hi all, > > > > > > could it be that IoTDB doesn't support prepared statements? When I > > > try > > > > > to use the SQL component of Camel, this is the error I get: > > > > > https://i.imgur.com/HOJgh0H.png > > > > > > > > > > > > when I use JDBC component I get an error message "Not support > > > Commit". I > > > > > am confused now on how to use camel with IoTDB. > > > > > > Etienne > > > > > > > > > >
