Chapter 20. Ceph Sink
Upload data to an Ceph Bucket managed by a Object Storage Gateway.
In the header, you can optionally set the file / ce-file property to specify the name of the file to upload.
If you do not set the property in the header, the Kamelet uses the exchange ID for the file name.
20.1. Configuration Options Copy linkLink copied to clipboard!
The following table summarizes the configuration options available for the ceph-sink Kamelet:
| Property | Name | Description | Type | Default | Example |
|---|---|---|---|---|---|
| accessKey * | Access Key | The access key. | string | ||
| bucketName * | Bucket Name | The Ceph Bucket name. | string | ||
| cephUrl * | Ceph Url Address | Set the Ceph Object Storage Address Url. | string | ||
| secretKey * | Secret Key | The secret key. | string | ||
| zoneGroup * | Bucket Zone Group | The bucket zone group. | string | ||
| autoCreateBucket | Autocreate Bucket | Specifies to automatically create the bucket. | boolean | False | |
| keyName | Key Name | The key name for saving an element in the bucket. | string |
* = Fields marked with an asterisk are mandatory.
20.2. Dependencies Copy linkLink copied to clipboard!
20.2.1. Quarkus dependencies Copy linkLink copied to clipboard!
20.3. Usage Copy linkLink copied to clipboard!
20.3.1. Camel JBang usage Copy linkLink copied to clipboard!
20.3.1.1. Prerequisites for JBang Copy linkLink copied to clipboard!
- Install JBang.
You have executed the following command:
jbang app install camel@apache/camel
jbang app install camel@apache/camelCopy to Clipboard Copied! Toggle word wrap Toggle overflow
20.3.1.2. Running a route with JBang Copy linkLink copied to clipboard!
Suppose you have a file named route.yaml with this content:
You can now run it directly through the following command.
camel run route.yaml
camel run route.yaml
20.3.2. Knative Sink Copy linkLink copied to clipboard!
You can use the ceph-sink Kamelet as a Knative sink by binding it to a Knative object.
ceph-sink-binding.yaml
20.3.3. Kafka Sink Copy linkLink copied to clipboard!
You can use the ceph-sink Kamelet as a Kafka sink by binding it to a Kafka topic.
ceph-sink-binding.yaml