홈
제품
Red Hat build of Apache Camel
4.10
Kamelets reference for Red Hat build of Apache Camel for Quarkus
Chapter 59. PostgreSQL Sink

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

Chapter 59. PostgreSQL Sink

Send data to a PostgreSQL Database.

This Kamelet expects a JSON-formatted body. Use key:value pairs to map the JSON fields and parameters. For example, here is a query:

'INSERT INTO accounts (username,city) VALUES (:#username,:#city)'

Here is example input for the example query:

'{ "username":"oscerd", "city":"Rome"}'

59.1. Configuration Options
링크 복사

The following table summarizes the configuration options available for the postgresql-sink Kamelet:

Expand

Property	Name	Description	Type	Default	Example
databaseName *	Database Name	The name of the PostgreSQL Database.	string
password *	Password	The password to access a secured PostgreSQL Database.	string
query *	Query	The query to execute against the PostgreSQL Database.	string		INSERT INTO accounts (username,city) VALUES (:#username,:#city)
serverName *	Server Name	The server name for the data source.	string		localhost
username *	Username	The username to access a secured PostgreSQL Database.	string
serverPort	Server Port	The server port for the data source.	string	5432

* = Fields marked with an asterisk are mandatory.

59.2. Dependencies
링크 복사

59.2.1. Quarkus dependencies
링크 복사

<dependencies>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifact>camel-quarkus-jackson</artifact>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifact>camel-quarkus-kamelet</artifact>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifact>camel-quarkus-sql</artifact>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.kamelets</groupId>
    <artifact>camel-kamelets-utils</artifact>
    <version>4.8.5</version>
  </dependency>
  <dependency>
    <groupId>org.apache.commons</groupId>
    <artifact>commons-dbcp2</artifact>
    <version>2.13.0</version>
  </dependency>
  <dependency>
    <groupId>org.postgresql</groupId>
    <artifact>postgresql</artifact>
    <version>42.7.6</version>
  </dependency>
</dependencies>

<dependencies>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifact>camel-quarkus-jackson</artifact>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifact>camel-quarkus-kamelet</artifact>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifact>camel-quarkus-sql</artifact>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.kamelets</groupId>
    <artifact>camel-kamelets-utils</artifact>
    <version>4.8.5</version>
  </dependency>
  <dependency>
    <groupId>org.apache.commons</groupId>
    <artifact>commons-dbcp2</artifact>
    <version>2.13.0</version>
  </dependency>
  <dependency>
    <groupId>org.postgresql</groupId>
    <artifact>postgresql</artifact>
    <version>42.7.6</version>
  </dependency>
</dependencies>

Copy to Clipboard

Toggle word wrap

59.3. Usage
링크 복사

59.3.1. Camel JBang usage
링크 복사

59.3.1.1. Prerequisites for JBang
링크 복사

Install JBang.
You have executed the following command:
```
jbang app install camel@apache/camel
```
```
jbang app install camel@apache/camel
```
Copy to Clipboard Toggle word wrap

59.3.1.2. Running a route with JBang
링크 복사

Suppose you have a file named route.yaml with this content:

- route:
    from:
      uri: "kamelet:timer-source"
      parameters:
        period: 10000
        message: 'test'
      steps:
        - to:
            uri: "kamelet:log-sink"

- route:
    from:
      uri: "kamelet:timer-source"
      parameters:
        period: 10000
        message: 'test'
      steps:
        - to:
            uri: "kamelet:log-sink"

Copy to Clipboard

Toggle word wrap

You can now run it directly through the following command.

camel run route.yaml

camel run route.yaml

Copy to Clipboard

Toggle word wrap

59.3.2. Knative Sink
링크 복사

You can use the postgresql-sink Kamelet as a Knative sink by binding it to a Knative object.

postgresql-sink-binding.yaml

apiVersion: camel.apache.org/v1
kind: Pipe
metadata:
  name: postgresql-sink-binding
spec:
  source:
    ref:
      kind: Channel
      apiVersion: messaging.knative.dev/v1
      name: mychannel
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1
      name: postgresql-sink
    properties:
      databaseName: "The Database Name"
      password: "The Password"
      query: "INSERT INTO accounts (username,city) VALUES (:#username,:#city)"
      serverName: "localhost"
      username: "The Username"

apiVersion: camel.apache.org/v1
kind: Pipe
metadata:
  name: postgresql-sink-binding
spec:
  source:
    ref:
      kind: Channel
      apiVersion: messaging.knative.dev/v1
      name: mychannel
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1
      name: postgresql-sink
    properties:
      databaseName: "The Database Name"
      password: "The Password"
      query: "INSERT INTO accounts (username,city) VALUES (:#username,:#city)"
      serverName: "localhost"
      username: "The Username"

Copy to Clipboard

Toggle word wrap

59.3.3. Kafka Sink
링크 복사

You can use the postgresql-sink Kamelet as a Kafka sink by binding it to a Kafka topic.

postgresql-sink-binding.yaml

apiVersion: camel.apache.org/v1
kind: Pipe
metadata:
  name: postgresql-sink-binding
spec:
  source:
    ref:
      kind: KafkaTopic
      apiVersion: kafka.strimzi.io/v1beta1
      name: my-topic
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1
      name: postgresql-sink
    properties:
      databaseName: "The Database Name"
      password: "The Password"
      query: "INSERT INTO accounts (username,city) VALUES (:#username,:#city)"
      serverName: "localhost"
      username: "The Username"

apiVersion: camel.apache.org/v1
kind: Pipe
metadata:
  name: postgresql-sink-binding
spec:
  source:
    ref:
      kind: KafkaTopic
      apiVersion: kafka.strimzi.io/v1beta1
      name: my-topic
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1
      name: postgresql-sink
    properties:
      databaseName: "The Database Name"
      password: "The Password"
      query: "INSERT INTO accounts (username,city) VALUES (:#username,:#city)"
      serverName: "localhost"
      username: "The Username"

Copy to Clipboard

Toggle word wrap

59.4. Kamelets source file
링크 복사

https://github.com/jboss-fuse/camel-kamelets/blob/camel-kamelets-4.10.3-branch/kamelets/postgresql-sink.kamelet.yaml

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

Chapter 59. PostgreSQL Sink

59.1. Configuration Options
링크 복사

59.2. Dependencies
링크 복사

59.2.1. Quarkus dependencies
링크 복사

59.3. Usage
링크 복사

59.3.1. Camel JBang usage
링크 복사

59.3.1.1. Prerequisites for JBang
링크 복사

59.3.1.2. Running a route with JBang
링크 복사

59.3.2. Knative Sink
링크 복사

59.3.3. Kafka Sink
링크 복사

59.4. Kamelets source file
링크 복사

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

Chapter 59. PostgreSQL Sink

59.1. Configuration Options링크 복사링크가 클립보드에 복사되었습니다!

59.2. Dependencies링크 복사링크가 클립보드에 복사되었습니다!

59.2.1. Quarkus dependencies링크 복사링크가 클립보드에 복사되었습니다!

59.3. Usage링크 복사링크가 클립보드에 복사되었습니다!

59.3.1. Camel JBang usage링크 복사링크가 클립보드에 복사되었습니다!

59.3.1.1. Prerequisites for JBang링크 복사링크가 클립보드에 복사되었습니다!

59.3.1.2. Running a route with JBang링크 복사링크가 클립보드에 복사되었습니다!

59.3.2. Knative Sink링크 복사링크가 클립보드에 복사되었습니다!

59.3.3. Kafka Sink링크 복사링크가 클립보드에 복사되었습니다!

59.4. Kamelets source file링크 복사링크가 클립보드에 복사되었습니다!

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

59.1. Configuration Options
링크 복사

59.2. Dependencies
링크 복사

59.2.1. Quarkus dependencies
링크 복사

59.3. Usage
링크 복사

59.3.1. Camel JBang usage
링크 복사

59.3.1.1. Prerequisites for JBang
링크 복사

59.3.1.2. Running a route with JBang
링크 복사

59.3.2. Knative Sink
링크 복사

59.3.3. Kafka Sink
링크 복사

59.4. Kamelets source file
링크 복사