tasks.py 文件源码

def sensu_result_delete(message):

    API_URL = settings.SENSU_API_URL + '/results/' + message['client'] + '/' + message['check']
    userAndPass = base64.b64encode(str.encode("%s:%s" % (settings.SENSU_API_USER, settings.SENSU_API_PASSWORD))).decode("ascii")
    headers = { 'X_REQUESTED_WITH' :'XMLHttpRequest',
               'Accept': 'application/json, text/javascript, */*; q=0.01',
               'Authorization' : 'Basic %s' %  userAndPass }

    try:
        request = http.request('DELETE', API_URL, headers=headers)   
        response = request.status

        if response == 204:
            request.release_conn()
            return True
        else:
            logger.error("sensu_result_delete api request failed: %s" % str(response))
            return False
    except:
        logger.error("sensu_result_delete failed deleting client: %s check: %s" % (message['client'], message['check']))
        raise