本項(xiàng)目使用celery 異步去同步項(xiàng)目在jenkins中的構(gòu)建信息植袍。

最終結(jié)果展示：

1. 在項(xiàng)目的構(gòu)建列表中點(diǎn)擊同步按鈕缝其，調(diào)用celery去jenkins同步所有構(gòu)建信息

   
   
   Paste_Image.png

2. 每隔12小時(shí)蓄诽，調(diào)用celery的定時(shí)任務(wù)去jenkins同步最新build信息

   
   
   Paste_Image.png

前提：已有redis服務(wù)并啟動(dòng)

1. 安裝celery

     pip install celery
     pip install redis
   

2. settings.py 配置

    BROKER_URL = 'redis://ip:6379/6'
    CELERY_RESULT_BACKEND = BROKER_URL
    CELERY_TIMEZONE = 'Asia/Shanghai'
    #時(shí)區(qū)不一致時(shí)會(huì)導(dǎo)致任務(wù)監(jiān)控不到
   

3. init.py

   from .celery import app as celery_app
   

4. celery.py 配置

    # ~*~ coding: utf-8 ~*~
    from __future__ import absolute_import, unicode_literals
    import os
    from celery import Celery
    from celery.schedules import crontab
    from django.conf import settings
   
    # set the default Django settings module for the 'celery' program.
    os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'Testmanager.settings')
    app = Celery('Testmanager')
   
    # Using a string here means the worker will not have to
    # pickle the object when using Windows.
    app.config_from_object('django.conf:settings')
    app.autodiscover_tasks(lambda: [app_config.split('.')[0]
                                for app_config in settings.INSTALLED_APPS])
     #定時(shí)任務(wù)配置
     app.conf.update(
    CELERYBEAT_SCHEDULE={
       'refresh-pci-last-build-info': {
            'task': 'devops.tasks.update_all_pcis_by_jenkins',
           'schedule': crontab(hour='*/12'),
            'args': (),
            }
        }
    )
   

5. task任務(wù)

   @shared_task
   def update_all_pcis_by_jenkins():
    jen = jenkins.Jenkins(jenkins_url, username=jenkins_user, password=jenkins_passwd)
    pcis = PCI.objects.all()
    for pci in pcis :
        job_name = pci.job_name
        lastBuild_Number = jen.get_job_info(job_name)['lastBuild']['number']
        if pci.last_build_number != lastBuild_Number :
            lastBuild_url = jen.get_build_info(job_name, lastBuild_Number)['url']  # 最后一次build號(hào)
            times = jen.get_build_info(job_name, lastBuild_Number)['timestamp']  # build的日期
            result = jen.get_build_info(job_name, lastBuild_Number)['result']
            pci.last_build_number = lastBuild_Number
            pci.last_build_result = result
            pci.last_build_url = lastBuild_url
            pci.last_update_time = timestamp2datetime(times)
            pci.save()
        print(job_name)
        print('已是最新版本')
   @shared_task
   def update_pcis_by_jenkins(job_name,pid):
     jen = jenkins.Jenkins(jenkins_url, username=jenkins_user, password=jenkins_passwd)
     print (job_name)
     pci = PCI.objects.get(id=pid)
     job_info_scm = jen.get_job_info(job_name)['scm']['_class']
    #{'_class': 'hudson.plugins.git.GitSCM'}
     print('job_info_scm')
     print(job_info_scm)
     if job_info_scm.find('git') != -1:
         pci.pro_scm = 'git'
    else:
        pci.pro_scm = 'svn'
     lastBuild_Number = jen.get_job_info(job_name)['lastBuild']['number']
     lastBuild_url = jen.get_build_info(job_name, lastBuild_Number)['url']# 最后一次build號(hào)
     times = jen.get_build_info(job_name, lastBuild_Number)['timestamp']# build的日期
     result = jen.get_build_info(job_name, lastBuild_Number)['result']
     pci.last_build_number = lastBuild_Number
     pci.last_build_result = result
     pci.last_build_url = lastBuild_url
     pci.last_update_time = timestamp2datetime(times)
     pci.save()
   

6. 啟動(dòng)celery 進(jìn)程

   celery -A Testmanager worker --loglevel=info
   #定時(shí)任務(wù)
   celery -A Testmanager beat --loglevel=info
   

加載已有的tasks

定時(shí)任務(wù)