227 lines
5.5 KiB
Bash
227 lines
5.5 KiB
Bash
#!/bin/bash
|
|
# ============================================
|
|
# celeryd - Starts the Celery worker daemon.
|
|
# ============================================
|
|
#
|
|
# :Usage: /etc/init.d/celeryd {start|stop|force-reload|restart|try-restart|status}
|
|
#
|
|
# :Configuration file: /etc/default/celeryev | /etc/default/celeryd
|
|
#
|
|
# To configure celeryd you probably need to tell it where to chdir.
|
|
#
|
|
# EXAMPLE CONFIGURATION
|
|
# =====================
|
|
#
|
|
# this is an example configuration for a Python project:
|
|
#
|
|
# /etc/default/celeryd:
|
|
#
|
|
# # Where to chdir at start.
|
|
# CELERYD_CHDIR="/opt/Myproject/"
|
|
#
|
|
# # Extra arguments to celeryev
|
|
# CELERYEV_OPTS="-x"
|
|
#
|
|
# # Name of the celery config module.#
|
|
# CELERY_CONFIG_MODULE="celeryconfig"
|
|
#
|
|
# # Camera class to use (required)
|
|
# CELERYEV_CAM = "myapp.Camera"
|
|
#
|
|
# EXAMPLE DJANGO CONFIGURATION
|
|
# ============================
|
|
#
|
|
# # Where the Django project is.
|
|
# CELERYD_CHDIR="/opt/Project/"
|
|
#
|
|
# # Name of the projects settings module.
|
|
# export DJANGO_SETTINGS_MODULE="MyProject.settings"
|
|
#
|
|
# # Path to celeryd
|
|
# CELERYEV="/opt/Project/manage.py"
|
|
#
|
|
# # Extra arguments to manage.py
|
|
# CELERYEV_OPTS="celeryev"
|
|
#
|
|
# # Camera class to use (required)
|
|
# CELERYEV_CAM="djcelery.snapshot.Camera"
|
|
#
|
|
# AVAILABLE OPTIONS
|
|
# =================
|
|
#
|
|
# * CELERYEV_OPTS
|
|
# Additional arguments to celeryd, see `celeryd --help` for a list.
|
|
#
|
|
# * CELERYD_CHDIR
|
|
# Path to chdir at start. Default is to stay in the current directory.
|
|
#
|
|
# * CELERYEV_PID_FILE
|
|
# Full path to the pidfile. Default is /var/run/celeryd.pid.
|
|
#
|
|
# * CELERYEV_LOG_FILE
|
|
# Full path to the celeryd logfile. Default is /var/log/celeryd.log
|
|
#
|
|
# * CELERYEV_LOG_LEVEL
|
|
# Log level to use for celeryd. Default is INFO.
|
|
#
|
|
# * CELERYEV
|
|
# Path to the celeryev program. Default is `celeryev`.
|
|
# You can point this to an virtualenv, or even use manage.py for django.
|
|
#
|
|
# * CELERYEV_USER
|
|
# User to run celeryev as. Default is current user.
|
|
#
|
|
# * CELERYEV_GROUP
|
|
# Group to run celeryev as. Default is current user.
|
|
#
|
|
# * VIRTUALENV
|
|
# Full path to the virtualenv environment to activate. Default is none.
|
|
|
|
### BEGIN INIT INFO
|
|
# Provides: celeryev
|
|
# Required-Start: $network $local_fs $remote_fs postgresql rabbitmq-server
|
|
# Required-Stop: $network $local_fs $remote_fs postgresql rabbitmq-server
|
|
# Default-Start: 2 3 4 5
|
|
# Default-Stop: 0 1 6
|
|
# Short-Description: celery event snapshots
|
|
### END INIT INFO
|
|
|
|
# Cannot use set -e/bash -e since the kill -0 command will abort
|
|
# abnormally in the absence of a valid process ID.
|
|
#set -e
|
|
|
|
DEFAULT_PID_FILE="/var/run/celeryev.pid"
|
|
DEFAULT_LOG_FILE="/var/log/celeryev.log"
|
|
DEFAULT_LOG_LEVEL="INFO"
|
|
DEFAULT_CELERYEV="/usr/bin/celeryev"
|
|
|
|
if test -f /etc/default/celeryd; then
|
|
. /etc/default/celeryd
|
|
fi
|
|
|
|
if test -f /etc/default/celeryev; then
|
|
. /etc/default/celeryev
|
|
fi
|
|
|
|
CELERYEV=${CELERYEV:-$DEFAULT_CELERYEV}
|
|
CELERYEV_PID_FILE=${CELERYEV_PID_FILE:-${CELERYEV_PIDFILE:-$DEFAULT_PID_FILE}}
|
|
CELERYEV_LOG_FILE=${CELERYEV_LOG_FILE:-${CELERYEV_LOGFILE:-$DEFAULT_LOG_FILE}}
|
|
CELERYEV_LOG_LEVEL=${CELERYEV_LOG_LEVEL:-${CELERYEV_LOG_LEVEL:-$DEFAULT_LOG_LEVEL}}
|
|
|
|
export CELERY_LOADER
|
|
|
|
if [ -z "$CELERYEV_CAM" ]; then
|
|
echo "Missing CELERYEV_CAM variable" 1>&2
|
|
exit
|
|
fi
|
|
|
|
CELERYEV_OPTS="$CELERYEV_OPTS -f $CELERYEV_LOG_FILE -l $CELERYEV_LOG_LEVEL -c $CELERYEV_CAM"
|
|
|
|
if [ -n "$2" ]; then
|
|
CELERYEV_OPTS="$CELERYEV_OPTS $2"
|
|
fi
|
|
|
|
CELERYEV_LOG_DIR=`dirname $CELERYEV_LOG_FILE`
|
|
CELERYEV_PID_DIR=`dirname $CELERYEV_PID_FILE`
|
|
if [ ! -d "$CELERYEV_LOG_DIR" ]; then
|
|
mkdir -p $CELERYEV_LOG_DIR
|
|
fi
|
|
if [ ! -d "$CELERYEV_PID_DIR" ]; then
|
|
mkdir -p $CELERYEV_PID_DIR
|
|
fi
|
|
|
|
# Extra start-stop-daemon options, like user/group.
|
|
if [ -n "$CELERYEV_USER" ]; then
|
|
DAEMON_OPTS="$DAEMON_OPTS --uid $CELERYEV_USER"
|
|
chown "$CELERYEV_USER" $CELERYEV_LOG_DIR $CELERYEV_PID_DIR
|
|
fi
|
|
if [ -n "$CELERYEV_GROUP" ]; then
|
|
DAEMON_OPTS="$DAEMON_OPTS --gid $CELERYEV_GROUP"
|
|
chgrp "$CELERYEV_GROUP" $CELERYEV_LOG_DIR $CELERYEV_PID_DIR
|
|
fi
|
|
|
|
CELERYEV_CHDIR=${CELERYEV_CHDIR:-$CELERYD_CHDIR}
|
|
if [ -n "$CELERYEV_CHDIR" ]; then
|
|
DAEMON_OPTS="$DAEMON_OPTS --workdir $CELERYEV_CHDIR"
|
|
fi
|
|
|
|
|
|
export PATH="${PATH:+$PATH:}/usr/sbin:/sbin"
|
|
|
|
check_dev_null() {
|
|
if [ ! -c /dev/null ]; then
|
|
echo "/dev/null is not a character device!"
|
|
exit 1
|
|
fi
|
|
}
|
|
|
|
wait_pid () {
|
|
pid=$1
|
|
forever=1
|
|
i=0
|
|
while [ $forever -gt 0 ]; do
|
|
kill -0 $pid 1>/dev/null 2>&1
|
|
if [ $? -eq 1 ]; then
|
|
echo "OK"
|
|
forever=0
|
|
else
|
|
kill -TERM "$pid"
|
|
i=$((i + 1))
|
|
if [ $i -gt 60 ]; then
|
|
echo "ERROR"
|
|
echo "Timed out while stopping (30s)"
|
|
forever=0
|
|
else
|
|
sleep 0.5
|
|
fi
|
|
fi
|
|
done
|
|
}
|
|
|
|
|
|
stop_evcam () {
|
|
echo -n "Stopping celeryev..."
|
|
if [ -f "$CELERYEV_PID_FILE" ]; then
|
|
wait_pid $(cat "$CELERYEV_PID_FILE")
|
|
else
|
|
echo "NOT RUNNING"
|
|
fi
|
|
}
|
|
|
|
start_evcam () {
|
|
echo "Starting celeryev..."
|
|
if [ -n "$VIRTUALENV" ]; then
|
|
source $VIRTUALENV/bin/activate
|
|
fi
|
|
$CELERYEV $CELERYEV_OPTS $DAEMON_OPTS --detach \
|
|
--pidfile="$CELERYEV_PID_FILE"
|
|
}
|
|
|
|
|
|
|
|
case "$1" in
|
|
start)
|
|
check_dev_null
|
|
start_evcam
|
|
;;
|
|
stop)
|
|
stop_evcam
|
|
;;
|
|
reload|force-reload)
|
|
echo "Use start+stop"
|
|
;;
|
|
restart)
|
|
echo "Restarting celery event snapshots" "celeryev"
|
|
stop_evcam
|
|
check_dev_null
|
|
start_evcam
|
|
;;
|
|
|
|
*)
|
|
echo "Usage: /etc/init.d/celeryev {start|stop|restart}"
|
|
exit 1
|
|
esac
|
|
|
|
exit 0
|
|
|