celeryevcam 5.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230
  1. #!/bin/bash
  2. # ============================================
  3. # celeryd - Starts the Celery worker daemon.
  4. # ============================================
  5. #
  6. # :Usage: /etc/init.d/celeryd {start|stop|force-reload|restart|try-restart|status}
  7. #
  8. # :Configuration file: /etc/default/celeryev | /etc/default/celeryd
  9. #
  10. # To configure celeryd you probably need to tell it where to chdir.
  11. #
  12. # EXAMPLE CONFIGURATION
  13. # =====================
  14. #
  15. # this is an example configuration for a Python project:
  16. #
  17. # /etc/default/celeryd:
  18. #
  19. # # Where to chdir at start.
  20. # CELERYD_CHDIR="/opt/Myproject/"
  21. #
  22. # # Extra arguments to celeryev
  23. # CELERYEV_OPTS="-x"
  24. #
  25. # # Name of the celery config module.#
  26. # CELERY_CONFIG_MODULE="celeryconfig"
  27. #
  28. # # Camera class to use (required)
  29. # CELERYEV_CAM = "myapp.Camera"
  30. #
  31. # EXAMPLE DJANGO CONFIGURATION
  32. # ============================
  33. #
  34. # # Where the Django project is.
  35. # CELERYD_CHDIR="/opt/Project/"
  36. #
  37. # # Name of the projects settings module.
  38. # export DJANGO_SETTINGS_MODULE="settings"
  39. #
  40. # # Path to celeryd
  41. # CELERYEV="/opt/Project/manage.py"
  42. #
  43. # # Extra arguments to manage.py
  44. # CELERYEV_OPTS="celeryev"
  45. #
  46. # # Camera class to use (required)
  47. # CELERYEV_CAM = "djcelery.snapshot.Camera"
  48. #
  49. # AVAILABLE OPTIONS
  50. # =================
  51. #
  52. # * CELERYEV_OPTS
  53. # Additional arguments to celeryd, see `celeryd --help` for a list.
  54. #
  55. # * CELERYD_CHDIR
  56. # Path to chdir at start. Default is to stay in the current directory.
  57. #
  58. # * CELERYEV_PID_FILE
  59. # Full path to the pidfile. Default is /var/run/celeryd.pid.
  60. #
  61. # * CELERYEV_LOG_FILE
  62. # Full path to the celeryd logfile. Default is /var/log/celeryd.log
  63. #
  64. # * CELERYEV_LOG_LEVEL
  65. # Log level to use for celeryd. Default is INFO.
  66. #
  67. # * CELERYEV
  68. # Path to the celeryev program. Default is `celeryev`.
  69. # You can point this to an virtualenv, or even use manage.py for django.
  70. #
  71. # * CELERYEV_USER
  72. # User to run celeryev as. Default is current user.
  73. #
  74. # * CELERYEV_GROUP
  75. # Group to run celeryev as. Default is current user.
  76. #
  77. # * VIRTUALENV
  78. # Full path to the virtualenv environment to activate. Default is none.
  79. ### BEGIN INIT INFO
  80. # Provides: celeryev
  81. # Required-Start: $network $local_fs $remote_fs
  82. # Required-Stop: $network $local_fs $remote_fs
  83. # Default-Start: 2 3 4 5
  84. # Default-Stop: 0 1 6
  85. # Short-Description: celery event snapshots
  86. ### END INIT INFO
  87. # Cannot use set -e/bash -e since the kill -0 command will abort
  88. # abnormally in the absence of a valid process ID.
  89. #set -e
  90. DEFAULT_PID_FILE="/var/run/celeryev.pid"
  91. DEFAULT_LOG_FILE="/var/log/celeryev.log"
  92. DEFAULT_LOG_LEVEL="INFO"
  93. DEFAULT_CELERYEV="/usr/bin/celeryev"
  94. if test -f /etc/default/celeryd; then
  95. . /etc/default/celeryd
  96. fi
  97. if test -f /etc/default/celeryev; then
  98. . /etc/default/celeryev
  99. fi
  100. CELERYEV=${CELERYEV:-$DEFAULT_CELERYEV}
  101. CELERYEV_PID_FILE=${CELERYEV_PID_FILE:-${CELERYEV_PIDFILE:-$DEFAULT_PID_FILE}}
  102. CELERYEV_LOG_FILE=${CELERYEV_LOG_FILE:-${CELERYEV_LOGFILE:-$DEFAULT_LOG_FILE}}
  103. CELERYEV_LOG_LEVEL=${CELERYEV_LOG_LEVEL:-${CELERYEV_LOG_LEVEL:-$DEFAULT_LOG_LEVEL}}
  104. export CELERY_LOADER
  105. CELERYEV_OPTS="$CELERYEV_OPTS -f $CELERYEV_LOG_FILE -l $CELERYEV_LOG_LEVEL"
  106. if [ -z "$CELERYEV_CAM" ]; then
  107. echo "Missing CELERYEV_CAM variable" 1>&2
  108. exit
  109. fi
  110. CELERYEV_OPTS="$CELERYEV_OPTS -c $CELERYEV_CAM"
  111. if [ -n "$2" ]; then
  112. CELERYEV_OPTS="$CELERYEV_OPTS $2"
  113. fi
  114. CELERYEV_LOG_DIR=`dirname $CELERYEV_LOG_FILE`
  115. CELERYEV_PID_DIR=`dirname $CELERYEV_PID_FILE`
  116. if [ ! -d "$CELERYEV_LOG_DIR" ]; then
  117. mkdir -p $CELERYEV_LOG_DIR
  118. fi
  119. if [ ! -d "$CELERYEV_PID_DIR" ]; then
  120. mkdir -p $CELERYEV_PID_DIR
  121. fi
  122. # Extra start-stop-daemon options, like user/group.
  123. if [ -n "$CELERYEV_USER" ]; then
  124. DAEMON_OPTS="$DAEMON_OPTS --uid $CELERYEV_USER"
  125. chown "$CELERYEV_USER" $CELERYBEAT_LOG_DIR $CELERYEV_PID_DIR
  126. fi
  127. if [ -n "$CELERYEV_GROUP" ]; then
  128. DAEMON_OPTS="$DAEMON_OPTS --gid $CELERYEV_GROUP"
  129. chown "$CELERYEV_GROUP" $CELERYBEAT_LOG_DIR $CELERYEV_PID_DIR
  130. fi
  131. if [ -n "$CELERYEV_CHDIR" ]; then
  132. DAEMON_OPTS="$DAEMON_OPTS --workdir $CELERYEV_CHDIR"
  133. elif [ -n "$CELERYD_CHDIR" ]; then
  134. DAEMON_OPTS="$DAEMON_OPTS --workdir $CELERYD_CHDIR"
  135. fi
  136. export PATH="${PATH:+$PATH:}/usr/sbin:/sbin"
  137. check_dev_null() {
  138. if [ ! -c /dev/null ]; then
  139. echo "/dev/null is not a character device!"
  140. exit 1
  141. fi
  142. }
  143. wait_pid () {
  144. pid=$1
  145. forever=1
  146. i=0
  147. while [ $forever -gt 0 ]; do
  148. kill -0 $pid 1>/dev/null 2>&1
  149. if [ ! $? ]; then
  150. echo "OK"
  151. forever=0
  152. else
  153. kill -TERM "$pid"
  154. i=$((i + 1))
  155. if [ $i -gt 60 ]; then
  156. echo "ERROR"
  157. echo "Timed out while stopping (30s)"
  158. forever=0
  159. else
  160. sleep 0.5
  161. fi
  162. fi
  163. done
  164. }
  165. stop_evcam () {
  166. echo -n "Stopping celeryev..."
  167. if [ -f "$CELERYEV_PID_FILE" ]; then
  168. wait_pid $(cat "$CELERYEV_PID_FILE")
  169. else
  170. echo "NOT RUNNING"
  171. fi
  172. }
  173. start_evcam () {
  174. echo "Starting celeryev..."
  175. if [ -n "$VIRTUALENV" ]; then
  176. source $VIRTUALENV/bin/activate
  177. fi
  178. $CELERYEV $CELERYEV_OPTS $DAEMON_OPTS --detach \
  179. --pidfile="$CELERYEV_PID_FILE"
  180. }
  181. case "$1" in
  182. start)
  183. check_dev_null
  184. start_evcam
  185. ;;
  186. stop)
  187. stop_evcam
  188. ;;
  189. reload|force-reload)
  190. echo "Use start+stop"
  191. ;;
  192. restart)
  193. log_daemon_msg "Restarting celery event snapshots" "celeryev"
  194. stop_evcam
  195. check_dev_null
  196. start_evcam
  197. ;;
  198. *)
  199. echo "Usage: /etc/init.d/celeryev {start|stop|restart}"
  200. exit 1
  201. esac
  202. exit 0