tasks.py 文件源码

def sensu_client_delete(message):

    API_URL = settings.SENSU_API_URL + '/clients/' + message['client']
    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 == 202:
            request.release_conn()
            return True
        else:
            logger.error("sensu_client_delete api request failed: %s" % str(response))
            return False
    except:
        logger.error("sensu_client_delete failed deleting client: %s" % message['client'])
        raise