celeryd 3.0 KB

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