跳到主要内容

Tencent Cloud SCF Sink

Introduction

The Tencent Cloud SCF Sink is a Vanus Connector that aims to handle incoming CloudEvents in a way that extracts the data part of the original event and Tencent Cloud invoke SCF function

Quickstart

Prerequisites

  • Have a container runtime (i.e., docker).
  • Have a Tencent Cloud Account and SCF function

create config file

cat << EOF > config.yml
port: 8080
secret:
secret_id: ABID570jkkngFWl7uY3QchbdUXVIuNisywoA
secret_key: xxxxxx
function:
name: "xxxxxxxxx"
region: "ap-beijing"
namespace: "default"
EOF
NameRequiredDefaultDescription
portNo8080the port which the Tencent Cloud SCF Sink listens on
secret.secret_idYESthe Tencent Cloud cam secretId
secret.secret_keyYESthe Tencent Cloud SCF cam secretKey
function.regionYESwhich region the function was created
function.nameYESfunction name will be invoked
function.namespaceYESwhich namespace the function was created

The Tencent Cloud SCF Sink tries to find the config file at /vanus-connect/config/config.yml by default. You can specify the position of config file by setting the environment variable CONNECTOR_CONFIG for your connector.

Start with Docker

docker run -it --rm \
-p 31080:8080 \
-v ${PWD}:/vanus-connect/config \
--name sink-tencentcloud-scf public.ecr.aws/vanus/connector/sink-tencentcloud-scf

Test

Open a terminal and use following command to send a CloudEvent to the Sink.

curl --location --request POST 'localhost:8080' \
--header 'Content-Type: application/cloudevents+json' \
--data-raw '{
"id": "53d1c340-551a-11ed-96c7-8b504d95037c",
"source": "local",
"specversion": "1.0",
"type": "xxxx",
"datacontenttype": "application/json",
"time": "2022-10-26T10:38:29.345Z",
"data": {
"Records": [
{
"cos": "xxxx"
},
{
"cos": "yyy"
}
]
}
}'

the data will be as payload to invoke function

you can see logs in SCF console

log.png

Clean resource

docker stop sink-tencentcloud-scf

Run in Kubernetes

kubectl apply -f sink-tencentcloud-scf.yaml
apiVersion: v1
kind: Service
metadata:
name: sink-tencentcloud-scf
namespace: vanus
spec:
selector:
app: sink-tencentcloud-scf
type: ClusterIP
ports:
- port: 8080
name: sink-tencentcloud-scf
---
apiVersion: v1
kind: ConfigMap
metadata:
name: sink-tencentcloud-scf
namespace: vanus
data:
config.yml: |-
port: 8080
secret:
secret_id: ABID570jkkngFWl7uY3QchbdUXVIuNisywoA
secret_key: xxxxxx
function:
name: "xxxxxx"
region: "ap-beijing"
namespace: "default"
debug: false

---
apiVersion: apps/v1
kind: Deployment
metadata:
name: sink-tencentcloud-scf
namespace: vanus
labels:
app: sink-tencentcloud-scf
spec:
selector:
matchLabels:
app: sink-tencentcloud-scf
replicas: 1
template:
metadata:
labels:
app: sink-tencentcloud-scf
spec:
containers:
- name: sink-tencentcloud-scf
image: public.ecr.aws/vanus/connector/sink-tencentcloud-scf
imagePullPolicy: Always
ports:
- name: http
containerPort: 8080
volumeMounts:
- name: config
mountPath: /vanus-connect/config
volumes:
- name: config
configMap:
name: sink-tencentcloud-scf

Integrate with Vanus

This section shows how a sink connector can receive CloudEvents from a running Vanus cluster.

  1. Run the sink-tencentcloud-scf.yaml
kubectl apply -f sink-tencentcloud-scf.yaml
  1. Create an eventbus
vsctl eventbus create --name quick-start
  1. Create a subscription (the sink should be specified as the sink service address or the host name with its port)
vsctl subscription create \
--name quick-start \
--eventbus quick-start \
--sink 'http://sink-tencentcloud-scf:8080'