Comment créer le service Windows de céleri?

J'ai la réponse d'un autre site Web. Celeryd (Daemon Service for Ceery) est exécuté en tant qu'application de Soulet, à la recherche de 'Spast Windows Service' mène-moi ici . Il décrit comment exécuter une application de pylônes en tant que service Windows. Étant nouveau dans le cadre de diffamation et hébergement de services Web Python, il n'a pas traversé d'avis pour le vérifier au début. Mais cette solution fonctionne pour le céleri avec un léger changement ici et là dans le script.

J'ai modifié le script pour faciliter la modification des paramètres de céleri. Les changements essentiels sont: P>

1. Créez un fichier INI avec les paramètres du service de céleri (indiqué ci-dessous) LI>
2. Créez un script Python pour créer un service Windows. LI> ol>

   Paramètres de fichier INI (céleryd.ini): p> xxx pré>

   script python pour créer un service Windows (céleryservice.py): p>

   """
   The most basic (working) Windows service possible.
   Requires Mark Hammond's pywin32 package.  
   Most of the code was taken from a  CherryPy 2.2 example of how to set up a service
   """
   import pkg_resources
   import win32serviceutil
   from paste.script.serve import ServeCommand as Server
   import os, sys
   import ConfigParser
   
   import win32service
   import win32event
   
   SCRIPT_DIR          = os.path.abspath(os.path.dirname(__file__))
   INI_FILE            = 'celeryd.ini'
   SERV_SECTION        = 'celery:service'
   SERV_NAME           = 'service_name'
   SERV_DISPLAY_NAME   = 'service_display_name'
   SERV_DESC           = 'service_description'
   SERV_LOG_FILE       = 'service_logfile'
   SERV_APPLICATION    = 'celeryd'
   SERV_LOG_FILE_VAR   = 'CELERYD_LOG_FILE'
   
   # Default Values
   SERV_NAME_DEFAULT           = 'CeleryService'
   SERV_DISPLAY_NAME_DEFAULT   = 'Celery Service'
   SERV_DESC_DEFAULT           = 'WSCGI Windows Celery Service'
   SERV_LOG_FILE_DEFAULT       = r'D:\logs\celery.log'
   
   class DefaultSettings(object):
       def __init__(self):
           if SCRIPT_DIR:
               os.chdir(SCRIPT_DIR)
           # find the ini file
           self.ini = os.path.join(SCRIPT_DIR,INI_FILE)
           # create a config parser opject and populate it with the ini file
           c = ConfigParser.SafeConfigParser()
           c.read(self.ini)
           self.c = c
   
       def getDefaults(self):
           '''
           Check for and get the default settings
           '''
           if (
               (not self.c.has_section(SERV_SECTION)) or
               (not self.c.has_option(SERV_SECTION, SERV_NAME)) or
               (not self.c.has_option(SERV_SECTION, SERV_DISPLAY_NAME)) or
               (not self.c.has_option(SERV_SECTION, SERV_DESC)) or
               (not self.c.has_option(SERV_SECTION, SERV_LOG_FILE))
               ):
               print 'setting defaults'
               self.setDefaults()
           service_name = self.c.get(SERV_SECTION, SERV_NAME)
           service_display_name = self.c.get(SERV_SECTION, SERV_DISPLAY_NAME)
           service_description = self.c.get(SERV_SECTION, SERV_DESC)
           iniFile = self.ini
           service_logfile = self.c.get(SERV_SECTION, SERV_LOG_FILE)
           return service_name, service_display_name, service_description, iniFile, service_logfile
   
       def setDefaults(self):
           '''
           set and add the default setting to the ini file
           '''
           if not self.c.has_section(SERV_SECTION):
               self.c.add_section(SERV_SECTION)
           self.c.set(SERV_SECTION, SERV_NAME, SERV_NAME_DEFAULT)
           self.c.set(SERV_SECTION, SERV_DISPLAY_NAME, SERV_DISPLAY_NAME_DEFAULT)
           self.c.set(SERV_SECTION, SERV_DESC, SERV_DESC_DEFAULT)
           self.c.set(SERV_SECTION, SERV_LOG_FILE, SERV_LOG_FILE_DEFAULT)
           cfg = file(self.ini, 'wr')
           self.c.write(cfg)
           cfg.close()
           print '''
   you must set the celery:service section service_name, service_display_name,
   and service_description options to define the service 
   in the %s file
   ''' % self.ini
           sys.exit()
   
   
   class CeleryService(win32serviceutil.ServiceFramework):
       """NT Service."""
   
       d = DefaultSettings()
       service_name, service_display_name, service_description, iniFile, logFile = d.getDefaults()
   
       _svc_name_ = service_name
       _svc_display_name_ = service_display_name
       _svc_description_ = service_description
   
       def __init__(self, args):
           win32serviceutil.ServiceFramework.__init__(self, args)
           # create an event that SvcDoRun can wait on and SvcStop
           # can set.
           self.stop_event = win32event.CreateEvent(None, 0, 0, None)
   
       def SvcDoRun(self):
           os.chdir(SCRIPT_DIR)
           s = Server(SERV_APPLICATION)
           os.environ[SERV_LOG_FILE_VAR] = self.logFile
           s.run([self.iniFile])
           win32event.WaitForSingleObject(self.stop_event, win32event.INFINITE)
   
       def SvcStop(self):
           self.ReportServiceStatus(win32service.SERVICE_STOP_PENDING)
           #win32event.SetEvent(self.stop_event)
           self.ReportServiceStatus(win32service.SERVICE_STOPPED)
           sys.exit()
   
   if __name__ == '__main__':
       win32serviceutil.HandleCommandLine(CeleryService)
   

La réponse acceptée ne demande pas en cours d'exécution de céleri avec une application Django. Mais il m'a inspiré pour trouver une solution pour faire fonctionner le céleri en tant que service Windows avec Django. Notez que ce qui suit est pour les projets Django seulement. Il peut fonctionner avec d'autres applications, avec quelques modifications.

La discussion suivante suppose Python> = 3.6 et RabbitMQ sont déjà installés, et rabbitmq-server code> est en cours d'exécution sur localhost code>. p>

Créer un celery_service.py de fichier (ou tout ce que vous aimez) dans votre dossier de niveau supérieur de projet Django, même niveau que manage.py, avec le contenu suivant: p>

python celery_service.py install
python celery_service.py start
python celery_service.py stop
python celery_service.py remove