def push_to_ffwd()

in postgresql_metrics/metrics_logic.py [0:0]

• 9 lines of code
• 2 McCabe index (conditional complexity)

def push_to_ffwd(metric_dicts, ffwd_addr, data_formatter=json.dumps):
    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    try:
        for metric in metric_dicts:
            data = data_formatter(metric)
            LOG.debug('send UDP packet to {} with data:\n{}', ffwd_addr, data)
            s.sendto(bytes(data, 'UTF-8'), ffwd_addr)
    finally:
        s.close()