celeryd 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140
  1. #! /bin/sh
  2. ### BEGIN INIT INFO
  3. # Provides: celeryd
  4. # Required-Start:
  5. # Required-Stop:
  6. # Default-Start: 2 3 4 5
  7. # Default-Stop: 1
  8. # Short-Description: celery task worker daemon
  9. ### END INIT INFO
  10. set -e
  11. VIRTUALENV=/opt/Opal/current
  12. DJANGO_PROJECT_DIR=/opt/Opal/release/opal
  13. DJANGO_SETTINGS_MODULE=settings
  14. CELERYD_PID_FILE="/var/run/celeryd.pid"
  15. CELERYD_LOG_FILE="/var/log/celeryd.log"
  16. CELERYD_LOG_LEVEL="INFO"
  17. CELERYD="celeryd"
  18. export DJANGO_SETTINGS_MODULE
  19. # /etc/init.d/ssh: start and stop the celery task worker daemon.
  20. if test -f /etc/default/celeryd; then
  21. . /etc/default/celeryd
  22. fi
  23. . /lib/lsb/init-functions
  24. chdir $DJANGO_PROJECT_DIR
  25. CELERYD_OPTS="-f $CELERYD_LOG_FILE -l $CELERYD_LOG_LEVEL -p \
  26. $CELERYD_PID_FILE -d"
  27. if [ -n "$2" ]; then
  28. CELERYD_OPTS="$CELERYD_OPTS $2"
  29. fi
  30. # Are we running from init?
  31. run_by_init() {
  32. ([ "$previous" ] && [ "$runlevel" ]) || [ "$runlevel" = S ]
  33. }
  34. check_dev_null() {
  35. if [ ! -c /dev/null ]; then
  36. if [ "$1" = log_end_msg ]; then
  37. log_end_msg 1 || true
  38. fi
  39. if ! run_by_init; then
  40. log_action_msg "/dev/null is not a character device!"
  41. fi
  42. exit 1
  43. fi
  44. }
  45. export PATH="${PATH:+$PATH:}/usr/sbin:/sbin"
  46. if [ ! -n "$VIRTUALENV" ]; then
  47. . "$VIRTUALENV/current/bin/activate"
  48. export PATH="$VIRTUALENV/current/bin:$PATH"
  49. fi
  50. case "$1" in
  51. start)
  52. check_dev_null
  53. log_daemon_msg "Starting celery task worker server" "celeryd"
  54. if start-stop-daemon --start --quiet --oknodo --pidfile $CELERYD_PID_FILE --exec $CELERYD -- $CELERYD_OPTS; then
  55. log_end_msg 0
  56. else
  57. log_end_msg 1
  58. fi
  59. ;;
  60. stop)
  61. log_daemon_msg "Stopping celery task worker server" "celeryd"
  62. if start-stop-daemon --stop --quiet --oknodo --pidfile $CELERYD_PID_FILE; then log_end_msg 0
  63. else
  64. log_end_msg 1
  65. fi
  66. ;;
  67. reload|force-reload)
  68. echo "Use start+stop"
  69. ;;
  70. restart)
  71. log_daemon_msg "Restarting celery task worker server" "celeryd"
  72. start-stop-daemon --stop --quiet --oknodo --retry 30 --pidfile $CELERYD_PID_FILE
  73. check_for_no_start log_end_msg
  74. check_dev_null log_end_msg
  75. if start-stop-daemon --start --quiet --oknodo --pidfile $CELERYD_PID_FILE --exec $CELERYD -- $CELERYD_OPTS; then
  76. log_end_msg 0
  77. else
  78. log_end_msg 1
  79. fi
  80. ;;
  81. try-restart)
  82. log_daemon_msg "Restarting celery task worker server" "celeryd"
  83. set +e
  84. start-stop-daemon --stop --quiet --retry 30 --pidfile $CELERYD_PID_FILE
  85. RET="$?"
  86. set -e
  87. case $RET in
  88. 0)
  89. # old daemon stopped
  90. check_dev_null log_end_msg
  91. if start-stop-daemon --start --quiet --oknodo --pidfile $CELERYD_PID_FILE --exec $CELERYD -- $CELERYD_OPTS; then
  92. log_end_msg 0
  93. else
  94. log_end_msg 1
  95. fi
  96. ;;
  97. 1)
  98. # daemon not running
  99. log_progress_msg "(not running)"
  100. log_end_msg 0
  101. ;;
  102. *)
  103. # failed to stop
  104. log_progress_msg "(failed to stop)"
  105. log_end_msg 1
  106. ;;
  107. esac
  108. ;;
  109. status)
  110. status_of_proc -p $CELERYD_PID_FILE $CELERYD celeryd && exit 0 || exit $?
  111. ;;
  112. *)
  113. log_action_msg "Usage: /etc/init.d/celeryd {start|stop|force-reload|restart|try-restart|status}"
  114. exit 1
  115. esac
  116. exit 0