Functions
Kubemq gcp Cloud Functions target connector allows services using kubemq server to access call a function target on gcp Cloud Function. The connector synchronously invokes a deployed Cloud Function, very limited traffic is allowed 16 per 100 seconds.

Prerequisites

The following are required to run the redis target connector:
  • kubemq cluster
  • Gcp Cloud function targe.
  • kubemq-targets deployment

Configuration

Kafka source connector configuration properties:
Properties Key
Required
Description
Example
project
yes
gcp project name
"testproject"
credentials
yes
gcp service account key location (json)
"TestTopic"
location_match
no
match missing function location (default true)
"true"
Example:
1
bindings:
2
- name: kubemq-query
3
source:
4
kind: kubemq.kubemq.query
5
name: kubemq-query
6
properties:
7
address: "kubemq-cluster:50000"
8
client_id: "kubemq-query-gcpfucntions-connector"
9
auth_token: ""
10
channel: "query.gcp.functions"
11
group: ""
12
auto_reconnect: "true"
13
reconnect_interval_seconds: "1"
14
max_reconnects: "0"
15
target:
16
kind: gcp.cloudfunctions
17
name: target-gcp-couldfunctions
18
properties:
19
project: "testproject"
20
credentials: "myKey"
21
location_match: "true"
Copied!

Usage

Get Request

Get request metadata setting:
Metadata Key
Required
Description
Possible values
name
yes
name of the gcp function
"test_function"
project
no
gcp project name (override parent value)
"testproject1"
location
no
gcp project location (missing value will be matched)
"us-central1"
Example:
1
{
2
"metadata": {
3
"name": "test_function",
4
"location": "us-central1"
5
},
6
"data": "eyJtZXNzYWdlIjoidGVzdCJ9"
7
}
Copied!
Last modified 11mo ago