pystuderxcom/example_api_msg.py at master · ankohanse/pystuderxcom · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
# Do not edit this file directly. It has been autogenerated from
# example_api_msg_async.py
import asyncio
from datetime import datetime
import logging
import sys

from pystuderxcom import AsyncXcomApiTcp, XcomApiTcp, XcomApiTcpMode
from helper import RunHelper

# Setup logging to StdOut
logging.basicConfig(stream=sys.stdout, level=logging.DEBUG)
logger = logging.getLogger(__name__)


def main():

    # When Moxa is configured as TCP Client (preferred mode):
    # api = AsyncXcomApiTcp(mode=XcomApiTcpMode.SERVER, listen_port=4001)
    #
    # When Moxa is configured as TCP Server:
    # api = AsyncXcomApiTcp(mode=XcomApiTcpMode.CLIENT, remote_ip=<moxa_ip>, remote_port=<moxa_port>)
    #
    # When Moxa is configured as UDP:
    # api = AsyncXcomApiUdp(remote_ip=<moxa_ip>, remote_port=<moxa_port>, local_port=4001)

    api = XcomApiTcp(mode=XcomApiTcpMode.SERVER, listen_port=4001)    # port number configured in Xcom-LAN/Moxa NPort
    try:
        if not api.start():
            logger.info(f"Did not connect to Xcom")
            return

        # Retrieve unique guid for this installation
        logger.info(f"")
        logger.info(f"Retrieve unique guid of this installation")

        value = api.request_guid()
        logger.info(f"Installation Guid: {value}")

        # Show flags.
        # These become available after the first request (value, guid, message) and updated after each next request
        logger.info(f"")
        logger.info(f"Status flags:")
        logger.info(f"  is new datalogger file present: {api.is_new_datalogger_file_present}")
        logger.info(f"  is sd-card full:                {api.is_sd_card_full}")
        logger.info(f"  is sd-card present:             {api.is_sd_card_present}")
        logger.info(f"  was rcc reseted:                {api.was_rcc_reseted}")
        logger.info(f"  is message pending:             {api.is_message_pending}")

        # Retrieve messages
        logger.info(f"")
        logger.info(f"Retrieve messages (10 most recent)")

        # Retrieving message #0 returns the most recent message.
        # But be aware that it will also clear the 'is_message_pending' flag
        idx = 0
        for idx in range(0, 10):
            msg = api.request_message(idx)
            logger.info(f"  msg #{idx} from {msg.source_address} at {datetime.fromtimestamp(msg.timestamp)}: {msg.message_string}")

            if msg.message_total <= 1:
                break

    except Exception as e:
        logger.info(f"Unexpected exception: {e}")

    finally:
        logger.info(f"")
        api.stop()


RunHelper.run(main)  # main loop