|
|
@ -22,24 +22,32 @@ DOLPHINSCHEDULER_BIN=${DOLPHINSCHEDULER_HOME}/bin |
|
|
|
DOLPHINSCHEDULER_SCRIPT=${DOLPHINSCHEDULER_HOME}/script |
|
|
|
DOLPHINSCHEDULER_SCRIPT=${DOLPHINSCHEDULER_HOME}/script |
|
|
|
DOLPHINSCHEDULER_LOGS=${DOLPHINSCHEDULER_HOME}/logs |
|
|
|
DOLPHINSCHEDULER_LOGS=${DOLPHINSCHEDULER_HOME}/logs |
|
|
|
|
|
|
|
|
|
|
|
# start postgresql |
|
|
|
# start database |
|
|
|
initPostgreSQL() { |
|
|
|
initDatabase() { |
|
|
|
echo "test postgresql service" |
|
|
|
echo "test ${DATABASE_TYPE} service" |
|
|
|
while ! nc -z ${POSTGRESQL_HOST} ${POSTGRESQL_PORT}; do |
|
|
|
while ! nc -z ${DATABASE_HOST} ${DATABASE_PORT}; do |
|
|
|
counter=$((counter+1)) |
|
|
|
counter=$((counter+1)) |
|
|
|
if [ $counter == 30 ]; then |
|
|
|
if [ $counter == 30 ]; then |
|
|
|
echo "Error: Couldn't connect to postgresql." |
|
|
|
echo "Error: Couldn't connect to ${DATABASE_TYPE}." |
|
|
|
exit 1 |
|
|
|
exit 1 |
|
|
|
fi |
|
|
|
fi |
|
|
|
echo "Trying to connect to postgresql at ${POSTGRESQL_HOST}:${POSTGRESQL_PORT}. Attempt $counter." |
|
|
|
echo "Trying to connect to ${DATABASE_TYPE} at ${DATABASE_HOST}:${DATABASE_PORT}. Attempt $counter." |
|
|
|
sleep 5 |
|
|
|
sleep 5 |
|
|
|
done |
|
|
|
done |
|
|
|
|
|
|
|
|
|
|
|
echo "connect postgresql service" |
|
|
|
echo "connect ${DATABASE_TYPE} service" |
|
|
|
v=$(sudo -u postgres PGPASSWORD=${POSTGRESQL_PASSWORD} psql -h ${POSTGRESQL_HOST} -p ${POSTGRESQL_PORT} -U ${POSTGRESQL_USERNAME} -d dolphinscheduler -tAc "select 1") |
|
|
|
if [ ${DATABASE_TYPE} = "mysql" ]; then |
|
|
|
if [ "$(echo '${v}' | grep 'FATAL' | wc -l)" -eq 1 ]; then |
|
|
|
v=$(mysql -h${DATABASE_HOST} -P${DATABASE_PORT} -u${DATABASE_USERNAME} --password=${DATABASE_PASSWORD} -D ${DATABASE_DATABASE} -e "select 1" 2>&1) |
|
|
|
echo "Error: Can't connect to database...${v}" |
|
|
|
if [ "$(echo ${v} | grep 'ERROR' | wc -l)" -eq 1 ]; then |
|
|
|
exit 1 |
|
|
|
echo "Error: Can't connect to database...${v}" |
|
|
|
|
|
|
|
exit 1 |
|
|
|
|
|
|
|
fi |
|
|
|
|
|
|
|
else |
|
|
|
|
|
|
|
v=$(sudo -u postgres PGPASSWORD=${DATABASE_PASSWORD} psql -h ${DATABASE_HOST} -p ${DATABASE_PORT} -U ${DATABASE_USERNAME} -d ${DATABASE_DATABASE} -tAc "select 1") |
|
|
|
|
|
|
|
if [ "$(echo ${v} | grep 'FATAL' | wc -l)" -eq 1 ]; then |
|
|
|
|
|
|
|
echo "Error: Can't connect to database...${v}" |
|
|
|
|
|
|
|
exit 1 |
|
|
|
|
|
|
|
fi |
|
|
|
fi |
|
|
|
fi |
|
|
|
|
|
|
|
|
|
|
|
echo "import sql data" |
|
|
|
echo "import sql data" |
|
|
@ -123,7 +131,7 @@ LOGFILE=/var/log/nginx/access.log |
|
|
|
case "$1" in |
|
|
|
case "$1" in |
|
|
|
(all) |
|
|
|
(all) |
|
|
|
initZK |
|
|
|
initZK |
|
|
|
initPostgreSQL |
|
|
|
initDatabase |
|
|
|
initMasterServer |
|
|
|
initMasterServer |
|
|
|
initWorkerServer |
|
|
|
initWorkerServer |
|
|
|
initApiServer |
|
|
|
initApiServer |
|
|
@ -134,25 +142,25 @@ case "$1" in |
|
|
|
;; |
|
|
|
;; |
|
|
|
(master-server) |
|
|
|
(master-server) |
|
|
|
initZK |
|
|
|
initZK |
|
|
|
initPostgreSQL |
|
|
|
initDatabase |
|
|
|
initMasterServer |
|
|
|
initMasterServer |
|
|
|
LOGFILE=${DOLPHINSCHEDULER_LOGS}/dolphinscheduler-master.log |
|
|
|
LOGFILE=${DOLPHINSCHEDULER_LOGS}/dolphinscheduler-master.log |
|
|
|
;; |
|
|
|
;; |
|
|
|
(worker-server) |
|
|
|
(worker-server) |
|
|
|
initZK |
|
|
|
initZK |
|
|
|
initPostgreSQL |
|
|
|
initDatabase |
|
|
|
initWorkerServer |
|
|
|
initWorkerServer |
|
|
|
initLoggerServer |
|
|
|
initLoggerServer |
|
|
|
LOGFILE=${DOLPHINSCHEDULER_LOGS}/dolphinscheduler-worker.log |
|
|
|
LOGFILE=${DOLPHINSCHEDULER_LOGS}/dolphinscheduler-worker.log |
|
|
|
;; |
|
|
|
;; |
|
|
|
(api-server) |
|
|
|
(api-server) |
|
|
|
initZK |
|
|
|
initZK |
|
|
|
initPostgreSQL |
|
|
|
initDatabase |
|
|
|
initApiServer |
|
|
|
initApiServer |
|
|
|
LOGFILE=${DOLPHINSCHEDULER_LOGS}/dolphinscheduler-api-server.log |
|
|
|
LOGFILE=${DOLPHINSCHEDULER_LOGS}/dolphinscheduler-api-server.log |
|
|
|
;; |
|
|
|
;; |
|
|
|
(alert-server) |
|
|
|
(alert-server) |
|
|
|
initPostgreSQL |
|
|
|
initDatabase |
|
|
|
initAlertServer |
|
|
|
initAlertServer |
|
|
|
LOGFILE=${DOLPHINSCHEDULER_LOGS}/dolphinscheduler-alert.log |
|
|
|
LOGFILE=${DOLPHINSCHEDULER_LOGS}/dolphinscheduler-alert.log |
|
|
|
;; |
|
|
|
;; |
|
|
|