您现在的位置是:首页 > 名人名句

SeaTunnel-web in K8S

作者:胡椒时间:2024-04-03 11:21:19分类:名人名句

简介  文章浏览阅读1.2k次,点赞33次,收藏20次。SeaTunnel-web in K8S_seatunnel web

点击全文阅读

下载,官网下载有问题,上dlcdn.apache.org下载
https://dlcdn.apache.org/seatunnel/seatunnel-web/1.0.0/apache-seatunnel-web-1.0.0-bin.tar.gz

apache-seatunnel-2.3.3中执行bin/install-plugin.sh下载connectors

下载web的源码

https://github.com/apache/seatunnel-web.git

seatunnel-server/seatunnel-app/src/main/bin/download_datasource.sh

将download_datasource.sh复制到/root/seatunnel/apache-seatunnel-web-1.0.0-bin/bin目录
sh download_datasource.sh 下载 datasource

vim conf/application.yml修改端口号和数据源信息

根据script目录下的数据表初始化脚本,把数据库建好 seatunnel_server_mysql.sql

将apache-seatunnel-2.3.4/conf目录下的hazelcast-client.yamlplugin-mapping.properties复制过来

hazelcast-client.yaml中的信息连接到之前部署好的SeaTunnel集群

参考:SeaTunnel 2.3.4 Cluster in K8S-CSDN博客

logback-spring.xml文件中的日志级别如果需要可改成debug方便调试


准备创建镜像文件

apache-seatunnel-2.3.3(重命名为:seatunnel-zeta)和apache-seatunnel-web-1.0.0-bin(重命名为:seatunnel,web依赖zeta连接集群)都放在一个容器中。

在镜像中配置相关的环境变量

SEATUNNEL_HOME=/opt/seatunnel-zeta
SEATUNNEL_WEB_HOME=/opt/seatunnel
ST_WEB_BASEDIR_PATH=/opt/seatunnel/ui


将connectors和plugins目录复制到web下,打包后拷贝到镜像中,然后镜像中编写的启动脚本会把该目录移动到seatunnel-zeta目录下,不然在web界面选择不了数据源,connectors又依赖plugins  
 cp -r /root/seatunnel/apache-seatunnel-2.3.3/connectors   /root/seatunnel/apache-seatunnel-web-1.0.0-bin/
 cp -r /root/seatunnel/apache-seatunnel-2.3.3/plugins   /root/seatunnel/apache-seatunnel-web-1.0.0-bin/

创建启动脚本 web自带的是后台启动,所以需要自己写个脚本在容器中前台运行
vi apache-seatunnel-web-1.0.0-bin/start.sh

一定要在bin目录下执行启动后的脚本  sh bin/seatunnel-backend-daemon.sh start ,不然找不到首页  jetty err_empty_response 404

参考:CentOs7.x安装部署SeaTunnelWeb遇到的坑_seatunnel unable to connect to any cluster-CSDN博客

#!/bin/bashcp /opt/seatunnel-zeta/lib/* /opt/seatunnel/libs/cp /opt/seatunnel/libs/datasource*.jar /opt/seatunnel-zeta/lib/mv -r /opt/seatunnel/connectors /opt/seatunnel-zeta/cd /opt/seatunnel/# 一定要在这个目录执行,不然找不到首页  jetty err_empty_response 404# https://blog.csdn.net/qq_34905631/article/details/135074860sh bin/seatunnel-backend-daemon.sh starttail -f /opt/seatunnel/logs/seatunnel-web.log

创建dockerfile

FROM flink:1.18ENV SEATUNNEL_VERSION="2.3.3"ENV SEATUNNEL_WEB_VERSION="1.0.0"COPY ./apache-seatunnel-web-${SEATUNNEL_WEB_VERSION}-bin.tar /opt/apache-seatunnel-web-${SEATUNNEL_WEB_VERSION}-bin.tarWORKDIR /optRUN tar -xvf apache-seatunnel-web-${SEATUNNEL_WEB_VERSION}-bin.tarRUN mv apache-seatunnel-web-${SEATUNNEL_WEB_VERSION}-bin seatunnelRUN rm -f /opt/apache-seatunnel-web-${SEATUNNEL_WEB_VERSION}-bin.tarWORKDIR /opt/seatunnelCOPY /apache-seatunnel-${SEATUNNEL_VERSION}-bin.tar.gz /opt/apache-seatunnel-${SEATUNNEL_VERSION}-bin.tar.gzWORKDIR /optRUN tar -xzvf apache-seatunnel-${SEATUNNEL_VERSION}-bin.tar.gzRUN mv apache-seatunnel-${SEATUNNEL_VERSION} seatunnel-zetaRUN rm -f /opt/apache-seatunnel-${SEATUNNEL_VERSION}-bin.tar.gzRUN export SEATUNNEL_HOME=/opt/seatunnel-zetaRUN export SEATUNNEL_WEB_HOME=/opt/seatunnelRUN export ST_WEB_BASEDIR_PATH=/opt/seatunnel/uiRUN export PATH=$PATH:$SEATUNNEL_HOME/bin:$SEATUNNEL_WEB_HOME/bin:$ST_WEB_BASEDIR_PATH/binENTRYPOINT ["sh", "/opt/seatunnel/start.sh"]


 tar -cvf apache-seatunnel-web-1.0.0-bin.tar apache-seatunnel-web-1.0.0-bin
 docker build -t yourharbor/yourlib/seatunnel-web:1.0.0 -f dockerfile-seatunnel-web-1.0.0-bin .
 docker push  yourharbor/yourlib/seatunnel-web:1.0.0


vi web.yaml

---apiVersion: apps/v1kind: Deploymentmetadata:  name: seatunnel-web-deployment  labels:    app: seatunnel-web-dev  namespace: seatunnelspec:  replicas: 1  selector:    matchLabels:      app: seatunnel-web-pod  template:    metadata:      labels:        app: seatunnel-web-pod    spec:      containers:      - name: seatunnel-web-serivce        image: yourharbor/yourlib/seatunnel-web:1.0.0        imagePullPolicy: Always      tolerations:      - effect: NoSchedule        key: node-role.kubernetes.io/control-plane---apiVersion: v1kind: Servicemetadata:  name: seatunnel-web-svc  labels:    app: seatunnel-web-svc  namespace: seatunnelspec:  selector:    app: seatunnel-web-pod  ports:  - name: seatunnel-web-ports    protocol: TCP    port: 8801    nodePort: 3xxxx    targetPort: 8801  type: NodePort


部署镜像
kubectl apply -f web.yaml
错了就删除
kubectl delete -f web.yaml
查看pod
kubectl get po -n seatunnel -owide
查看svc
kubectl get svc -n seatunnel -owide
describe
kubectl describe po -n seatunnel seatunnel-web-deployment-75f465bd8b-tcvmf     
logs
kubectl logs -f -n seatunnel seatunnel-web-deployment-75f465bd8b-tcvmf      
进去容器看看
kubectl exec -it -n seatunnel seatunnel-web-deployment-75f465bd8b-tcvmf      -- /bin/bash
容器里访问一下
curl localhost:8801 

admin/admin登录,创建数据源,开始建source和sink


MySQL-CDC数据源建好了连接MySQL8.0输入连接信息时没有Driver信息,所以实现MySQL8.0 CDC会出现找不到合适的Driver的异常

点击全文阅读

郑重声明:

本站所有活动均为互联网所得,如有侵权请联系本站删除处理

上一篇:优秀客户的表扬信

下一篇:返回列表

我来说两句