Links
Comment on page

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:
bindings:
- name: kubemq-query
source:
kind: kubemq.kubemq.query
name: kubemq-query
properties:
address: "kubemq-cluster:50000"
client_id: "kubemq-query-gcpfucntions-connector"
auth_token: ""
channel: "query.gcp.functions"
group: ""
auto_reconnect: "true"
reconnect_interval_seconds: "1"
max_reconnects: "0"
target:
kind: gcp.cloudfunctions
name: target-gcp-couldfunctions
properties:
project: "testproject"
credentials: "myKey"
location_match: "true"

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:
{
"metadata": {
"name": "test_function",
"location": "us-central1"
},
"data": "eyJtZXNzYWdlIjoidGVzdCJ9"
}
Last modified 2yr ago