adctk.http_publisher Namespace Reference

Classes
class	HttpPublisher
	Web server publisher implementation using the requests library. More...
class	HttpStatusCodeError

Functions
	handle_request_status (returned_data)
	http_post (method, url, headers, payload, timeouts)

Variables
dict	_defaults

Function Documentation

handle_request_status()

adctk.http_publisher.handle_request_status

(

returned_data

)

log status and raise if error is unexpected

def handle_request_status(returned_data):
    """log status and raise if error is unexpected"""
    status_code = returned_data.status_code
    if status_code < 200 or status_code > 300:
        logger.error(f"Status Code: {status_code}, Message: {returned_data.text}")
        raise HttpStatusCodeError(status_code)
    logger.info(f"Posting successful with status Code: {status_code}")
 

http_post()

adctk.http_publisher.http_post	(		method,
			url,
			headers,
			payload,
			timeouts
	)

log message send attempt

def http_post(method, url, headers, payload, timeouts):
    """log message send attempt"""
    logger.info(f"Posting to URL: {url}")
    logger.debug(f"Headers: {headers}, Payload: {payload}, timeout{timeouts}")
    ret = method(url, headers=headers, data=payload, timeout=timeouts)
    try:
        handle_request_status(ret)
    except HttpStatusCodeError as e:
        logger.info("adctk.http_post: exception %s for message %s", e, payload)
    return ret
 
 
#pylint: disable-next=too-many-instance-attributes

Variable Documentation

_defaults

dict adctk.http_publisher._defaults

protected

Initial value:

=  { "URL": Publisher.get_url_default(),
             "TIMEOUTS": Publisher.get_timeout_defaults(),
             "PORT": Publisher.get_port_default()}