.. note::
    :class: sphx-glr-download-link-note

    Click :ref:`here <sphx_glr_download_auto_examples_network_udp_dispatcher.py>` to download the full example code
.. rst-class:: sphx-glr-example-title

.. _sphx_glr_auto_examples_network_udp_dispatcher.py:


=============================
UDP Forwarder for ControlHost
=============================

A simple UDP forwarder for ControlHost messages.

This application is used to forward monitoring channel data from Ligier
to a given UDP address.




.. code-block:: python

    from __future__ import absolute_import, print_function, division

    import socket
    import sys

    import km3pipe as kp

    __author__ = "Tamas Gal"
    __email__ = "tgal@km3net.de"


    class UDPForwarder(kp.Module):
        def configure(self):
            self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
            self.counter = 0

        def process(self, blob):
            if str(blob['CHPrefix'].tag) == 'IO_MONIT':
                self.sock.sendto(blob['CHData'], ('127.0.0.1', 56017))
                if self.counter % 100 == 0:
                    sys.stdout.write('.')
                    sys.stdout.flush()
                self.counter += 1
            return blob


    pipe = kp.Pipeline()
    pipe.attach(
        kp.io.CHPump,
        host='localhost',
        port=5553,
        tags='IO_MONIT',
        timeout=60 * 60 * 24 * 7,
        max_queue=1000,
        timeit=True
    )
    pipe.attach(UDPForwarder)
    pipe.drain()

**Total running time of the script:** ( 0 minutes  0.000 seconds)


.. _sphx_glr_download_auto_examples_network_udp_dispatcher.py:


.. only :: html

 .. container:: sphx-glr-footer
    :class: sphx-glr-footer-example



  .. container:: sphx-glr-download

     :download:`Download Python source code: udp_dispatcher.py <udp_dispatcher.py>`



  .. container:: sphx-glr-download

     :download:`Download Jupyter notebook: udp_dispatcher.ipynb <udp_dispatcher.ipynb>`


.. only:: html

 .. rst-class:: sphx-glr-signature

    `Gallery generated by Sphinx-Gallery <https://sphinx-gallery.readthedocs.io>`_