这篇文章主要介绍了storm中基于k8s的安装示例，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。
首先我们先来编写一下Dockerfile
FROM ip:80/bigdata/centos7-jdk:1.8
#config storm env
ENV STORM_USER=storm \
STORM_INSTALL_BASE=/home/frank/platform \
STORM_HOME=/home/frank/platform/storm \
STORM_CONF_DIR=/home/frank/conf/storm \
STORM_DIR=/home/frank/hard_disk/storm \
STORM_BLOBS=/home/frank/hard_disk/storm/blobs \
STORM_NIMBUS=/home/frank/hard_disk/storm/nimbus \
STORM_LOG_DIR=/home/frank/logs/storm \
STORM_ROOT=/home/frank \
STORM_LOG=/home/frank/logs
ENV PATH $PATH:$STORM_HOME/bin
#add FLINK user and make dirs
RUN set -x \
&& adduser "$STORM_USER" \
&& mkdir -p "$STORM_INSTALL_BASE" "$STORM_CONF_DIR" "$STORM_LOG" "$STORM_LOG_DIR" "$STORM_BLOBS" "$STORM_NIMBUS"
#install storm libs
ADD apache-storm-1.2.2.tar.gz $STORM_INSTALL_BASE
RUN cd $STORM_INSTALL_BASE && ln -s -f apache-storm-1.2.2 storm && mkdir -p /home/storm
RUN chown -R "$STORM_USER:$STORM_USER" "$STORM_ROOT"
COPY docker-entrypoint.sh /home/storm
RUN chmod 755 /home/storm/docker-entrypoint.sh
USER storm
ENTRYPOINT ["/home/storm/docker-entrypoint.sh"]
其中的脚本如下：
#!/bin/sh
# If unspecified, the hostname of the container is taken as the JobManager address
ACTION_CMD="$1"
source /etc/profile
export STORM_CONF_DIR=/home/frank/conf/storm
export STORM_CONF_FILE=/home/frank/conf/storm/storm.yaml
sed -i -e "s/storm.zookeeper.servers: \[localhost\]/storm.zookeeper.servers: \[${STORM_ZK_QUORUM}\]/" /home/frank/conf/storm/storm.yaml
sed -i -e "s/storm.zookeeper.root: \"\/storm\"/storm.zookeeper.root: \/${STORM_ZK_ROOT}/" /home/frank/conf/storm/storm.yaml
# if use cluster model, pod ${JOB_CLUSTER_NAME}-0,${JOB_CLUSTER_NAME}-1 as jobmanager
if [ ${ACTION_CMD} == "cluster" ]; then
nimbuses=(${NIMBUS_HOSTS//,/ })
ACTION_CMD="supervisor"
for i in ${!nimbuses[@]}
do
if [ "$(hostname -s)" == "${nimbuses[i]}" ]; then
NIMBUS_ADDRESS=${NIMBUS_ADDRESS:-$(hostname -f)}
ACTION_CMD="nimbus"
sed -i -e "s/nimbus.seeds: \[localhost\]/nimbus.seeds: \["${NIMBUS_ADDRESS}"\]/" /home/frank/conf/storm/storm.yaml
echo "pod hostname match nimbus config host, change action to nimbus."
fi
done
fi
# if ha model, replace ha configuration
if [ ${ACTION_CMD} == "help" ]; then
echo "Usage: $(basename "$0") (cluster|nimbus|supervisor|ui|logviewer|help)"
exit 0
elif [ ${ACTION_CMD} == "nimbus" ]; then
echo "Starting nimbus ui logviewer supervisor"
nohup /home/frank/platform/storm/bin/storm nimbus >> /tmp/nimbus.log 2>&1 & \
nohup /home/frank/platform/storm/bin/storm ui >> /tmp/ui.log 2>&1 & \
/home/frank/platform/storm/bin/storm logviewer
elif [ ${ACTION_CMD} == "supervisor" ]; then
echo "Starting supervisor"
/home/frank/platform/storm/bin/storm supervisor
fi
镜像构建命令如下：
docker build --network=host -f Dockerfile -t ip:80/bigdata/storm:1.2.2 .
下面我们提供一下service的创建文件
apiVersion: v1
kind: Service
metadata:
name: storm-cluster
labels:
app: storm-cluster
namespace: storm
spec:
clusterIP: None
ports:
- port: 8080
name: ui
selector:
app: storm-cluster
apiVersion: apps/v1
kind: StatefulSet
metadata:
name: storm-cluster
namespace: storm
spec:
selector:
matchLabels:
app: storm-cluster
serviceName: storm-cluster
replicas: 4
podManagementPolicy: Parallel
template:
metadata:
labels:
app: storm-cluster
spec:
terminationGracePeriodSeconds: 2
containers:
- name: storm-cluster
imagePullPolicy: Always
image: ip:80/bigdata/storm:1.2.2
command: ["/bin/sleep"]
args: ["30d"]
volumeMounts:
- name: storm-conf
mountPath: /home/conf/storm
- name: storm-log
mountPath: /home/logs/storm
resources:
requests:
memory: "4096Mi"
cpu: 4
limits:
memory: "4096Mi"
cpu: 4
env:
- name: NIMBUS_HOSTS
value: "storm-cluster-2,storm-cluster-3"
- name: STORM_ZK_QUORUM
value: "ip"
- name: STORM_ZK_ROOT
value: "stormNew"
ports:
- containerPort: 6627
name: nimbus
- containerPort: 8000
name: logviewer
- containerPort: 8080
name: storm-ui
- containerPort: 6700
name: sv0
- containerPort: 6701
name: sv1
- containerPort: 6702
name: sv2
- containerPort: 6703
name: sv3
- containerPort: 22
name: ssh
volumes:
- name: storm-conf
configMap:
name: storm-conf
- name: storm-log
hostPath:
path: /stormtmp
type: Directory
service的创建脚本如下：
kubectl create -f storm-svc.yaml
statefulSet的创建脚本如下：
kubectl create -f storm-statefulSet.yaml
这个创建脚本要注意如下问题：
command:/bin/sleep
程序需要手动启动
/home/vipshop/hard_disk/storm
drwxr-xr-x 2 storm storm 4096 Jul 12 12:20 blobs
drwxr-xr-x 2 storm storm 4096 Jul 12 12:20 nimbus
drwxrwxr-x 5 storm storm 4096 Jul 29 00:00 supervisor
这个hard_disk目录需要有storm权限
注：nimbus.thrift.max_buffer_size: 10485760
这个参数需要是2的倍数
感谢你能够认真阅读完这篇文章，希望小编分享的“storm中基于k8s的安装示例”这篇文章对大家有帮助，同时也希望大家多多支持天达云，关注天达云行业资讯频道，更多相关知识等着你来学习!