This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch cql-source
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 01db0aadf98948e05d16230efd52dd0bedcf1c76
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Apr 23 13:33:12 2021 +0200
Added CassandraQL Source Kamelet
---
cql-source.kamelet.yaml | 82 +++++++++++++++++++++++++++++++++++++++++++++++++
1 file changed, 82 insertions(+)
diff --git a/cql-source.kamelet.yaml b/cql-source.kamelet.yaml
new file mode 100644
index 0000000..94ff24f
--- /dev/null
+++ b/cql-source.kamelet.yaml
@@ -0,0 +1,82 @@
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+ name: cassandraql-source
+ annotations:
+ camel.apache.org/kamelet.icon:
"data:image/svg+xml;base64,PHN2ZyBpZD0iTGF5ZXJfMSIgZGF0YS1uYW1lPSJMYXllciAxIiB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHdpZHRoPSI3NDQuMiIgaGVpZ2h0PSIxODEuODEiIHZpZXdCb3g9IjAgMCA3NDQuMiAxODEuODEiPjxkZWZzPjxzdHlsZT4uY2xzLTF7ZmlsbDojMjlhOWRlO30uY2xzLTJ7ZmlsbDojZmZmO30uY2xzLTN7ZmlsbDojMzNhNjc1O30uY2xzLTR7ZmlsbDojMzY1YzkzO30uY2xzLTV7ZmlsbDojOGRjMzQxO308L3N0eWxlPjwvZGVmcz48dGl0bGU+bmF0cy1sb2dvLWZyZWVsb2dvdmVjdG9ycy5uZXQ8L3RpdGxlPjxwYXRoIGNsYXNzPSJjbHMtMS
[...]
+ camel.apache.org/provider: "Apache Software Foundation"
+ labels:
+ camel.apache.org/kamelet.type: "source"
+spec:
+ definition:
+ title: "CassandraQL Source"
+ description: |-
+ Query a Cassandra cluster table.
+ required:
+ - host
+ - port
+ - keyspace
+ - username
+ - password
+ - query
+ properties:
+ host:
+ title: Host
+ description: Hostname(s) cassandra server(s). Multiple hosts can be
separated by comma.
+ type: string
+ example: localhosts
+ port:
+ title: Port
+ description: Port number of cassandra server(s)
+ type: string
+ example: 9042
+ keyspace:
+ title: Keyspace
+ description: Keyspace to use
+ type: string
+ example: customers
+ username:
+ title: Username
+ description: The username to use for accessing a secured Cassandra
Cluster
+ type: string
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ password:
+ title: Password
+ description: The password to use for accessing a secured Cassandra
Cluster
+ type: string
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ resultStrategy:
+ title: Result Strategy
+ description: The strategy to convert the result set of the query.
Possible values are ALL, ONE, LIMIT_10, LIMIT_100...
+ type: string
+ default: ALL
+ consistencyLevel:
+ title: Consistency Level
+ description: Consistency level to use. The value can be one of ANY,
ONE, TWO, THREE, QUORUM, ALL, LOCAL_QUORUM, EACH_QUORUM, SERIAL, LOCAL_SERIAL,
LOCAL_ONE
+ type: string
+ default: ANY
+ query:
+ title: Query
+ description: The query to execute against the Cassandra cluster table
+ type: string
+ default: ANY
+ types:
+ out:
+ mediaType: application/json
+ dependencies:
+ - "camel:jackson"
+ flow:
+ from:
+ uri: "cql://{{host}}:{{port}}/{{keyspace}}"
+ parameters:
+ username: "{{username}}"
+ password: "{{password}}"
+ cql: "{{query}}"
+ consistencyLevel: "{{consistencyLevel}}"
+ resultSetConversionStrategy: "{{resultStrategy}}"
+ steps:
+ - marshal:
+ json: {}
+ - to: "kamelet:sink"
