使用Helm部署
使用Helm快速部署Seatunnel集群。
准备
我们假设您的本地已经安装如下软件:
在您的本地环境中能够正常执行kubectl
和helm
命令。
以 minikube 为例, 您可以使用如下命令启动一个集群:
minikube start --kubernetes-version=v1.23.3
安装
使用默认配置安装
# Choose the corresponding version yourself
export VERSION=2.3.9
helm pull oci://registry-1.docker.io/apache/seatunnel-helm --version ${VERSION}
tar -xvf seatunnel-helm-${VERSION}.tgz
cd seatunnel-helm
helm install seatunnel .
如果您需要使用其他命名空间进行安装。
helm install seatunnel . -n <your namespace>
提交任务
当前默认的配置没有启用ingress,所以需要使用转发命令将master的restapi端口转发出来。
kubectl port-forward -n default svc/seatunnel-master 5801:5801
然后可以通过地址 "http://127.0.0.1/5801/" 访问master的restapi。
如果想要使用ingress, 需要更新 value.yaml
例如:
ingress:
enabled: true
host: "<your domain>"
然后更新seatunnel。
就可以使用域名http://<your domain>
进行访问了。
或者您可以直接进入master的POD执行curl命令。.
# 获取其中一个master pod
MASTER_POD=$(kubectl get po -l 'app.kubernetes.io/name=seatunnel-master' | sed '1d' | awk '{print $1}' | head -n1)
# 进入master pod
kubectl -n default exec -it $MASTER_POD -- /bin/bash
# 执行 restapi
curl http://127.0.0.1:5801/running-jobs
curl http://127.0.0.1:5801/system-monitoring-information
后面就可以使用rest-api-v2提交任务了。