Skip to main content

IEC61850/Modbus monitoring, control and data collection system

Reason this release was yanked:

missing async calls

Project description

DataSkipper Boat

DataSkipper Boat is a Modbus monitoring application that reads data from Modbus devices, processes it, and sends measurements and alerts to various destinations.

Features

  • Supports both Modbus TCP and Modbus RTU (Serial)
  • Reads registers from multiple Modbus devices
  • Processes measurements and checks for threshold violations
  • Generates alerts for threshold violations and significant changes
  • Stores measurements and alerts locally
  • Sends measurements and alerts to API endpoints
  • Sends alerts to Discord (and optionally other notification channels)
  • Handles connection failures and retries

Installation

  1. Clone the repository:
git clone https://github.com/yourusername/dataskipper-boat.git
cd dataskipper-boat
  1. Install the dependencies:
pip install -r requirements.txt

Configuration

The application uses YAML configuration files located in the config directory:

  • slave_config.yaml: Configuration for Modbus connections and devices
  • communication.yaml: Configuration for API endpoints, MQTT, and notification channels

Environment Variables

  • CONFIG_DIR: Path to the configuration directory (default: ~/config)
  • DATA_DIR: Path to the data directory (default: ~/data)

Usage

To run the application:

python main.py

To reset water counters:

python reset_water_counter.py

Testing

The application includes unit tests and integration tests. See tests/README.md for more information on running the tests.

Modbus Server Simulator

A Modbus server simulator is included for testing and development. To run the simulator:

python run_modbus_simulator.py

By default, the simulator will start on localhost:5020. You can specify a different host and port using the --host and --port options:

python run_modbus_simulator.py --host 0.0.0.0 --port 502

Project Structure

  • main.py: Main application entry point
  • reset_water_counter.py: Script to reset water counters
  • src/: Source code
    • interfaces/: Interface definitions
    • models/: Data models
    • services/: Services for communication with external systems
    • utils/: Utility functions
  • config/: Configuration files
  • tests/: Unit and integration tests

Development

Adding a New Device

To add a new Modbus device:

  1. Add a new client configuration to config/slave_config.yaml
  2. Define the registers to read from the device
  3. Configure thresholds and alerts as needed

Adding a New Notification Channel

To add a new notification channel:

  1. Create a new notifier class in src/services/notifiers/
  2. Implement the INotifier interface
  3. Add the new notifier to the list of notifiers in main.py

Releasing a New Version

To release a new version of DataSkipper Boat:

  1. Update version in pyproject.toml:

    # Edit pyproject.toml and increment the version number
    version = "1.0.1"  # or whatever the new version is
    
  2. Build and upload to PyPI:

    # Build the package
    python -m build
    
    # Upload to PyPI (requires PyPI account and API token)
    python -m twine upload dist/*
    
  3. Update target machines:

    # On each target machine, run:
    sudo -u dcu pip3 install --user --upgrade dataskipper-boat
    sudo supervisorctl restart dataskipper-boat-*:*
    

Setting Up a New Machine

To set up DataSkipper Boat on a new machine:

Prerequisites

  • Python 3.8+ installed
  • Supervisor installed (sudo apt install supervisor)
  • PyPI access (internet connection)

Setup Steps

  1. Install the application:

    # Install as user dcu (not root) to get correct paths
    sudo -u dcu pip3 install --user dataskipper-boat
    
  2. Create user and directories:

    # Create user if it doesn't exist
    sudo useradd -m -s /bin/bash dcu
    
    # Create directories for each instance
    sudo mkdir -p /home/dcu/config_lt_panel /home/dcu/data_lt_panel
    sudo mkdir -p /home/dcu/config_ht_panel /home/dcu/data_ht_panel
    sudo mkdir -p /home/dcu/config_relay_panel /home/dcu/data_relay_panel
    sudo chown -R dcu:dcu /home/dcu/
    
  3. Install supervisor config:

    # Copy supervisor config to target machine
    scp dataskipper-boat.conf target-machine:/tmp/
    
    # On target machine, install supervisor config
    sudo cp /tmp/dataskipper-boat.conf /etc/supervisor/conf.d/
    
    # Reload supervisor
    sudo supervisorctl reread
    sudo supervisorctl update
    
  4. Copy your configuration files:

    # Copy your YAML config files to each instance directory:
    cp your_configs/slave_config.yaml /home/dcu/config_lt_panel/
    cp your_configs/communication.yaml /home/dcu/config_lt_panel/
    
    cp your_configs/slave_config.yaml /home/dcu/config_ht_panel/
    cp your_configs/communication.yaml /home/dcu/config_ht_panel/
    
    cp your_configs/slave_config.yaml /home/dcu/config_relay_panel/
    cp your_configs/communication.yaml /home/dcu/config_relay_panel/
    
  5. Start the processes:

    sudo supervisorctl start dataskipper-boat-lt:*
    sudo supervisorctl start dataskipper-boat-ht:*
    sudo supervisorctl start dataskipper-boat-relay:*
    
  6. Verify everything is working:

    # Check status
    sudo supervisorctl status
    
    # Check logs
    sudo supervisorctl tail -f dataskipper-boat-lt stderr
    

Useful Management Commands

  • View status: sudo supervisorctl status
  • Check logs: sudo supervisorctl tail -f dataskipper-boat-lt stderr
  • Restart instance: sudo supervisorctl restart dataskipper-boat-lt:*
  • Update application: sudo -u dcu pip3 install --user --upgrade dataskipper-boat && sudo supervisorctl restart dataskipper-boat-*:*

License

This project is proprietary software owned by DataSailors. All rights reserved. Unauthorized copying, modification, distribution, or use of this software is strictly prohibited.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

dataskipper_boat-1.0.1.tar.gz (28.2 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

dataskipper_boat-1.0.1-py3-none-any.whl (32.8 kB view details)

Uploaded Python 3

File details

Details for the file dataskipper_boat-1.0.1.tar.gz.

File metadata

  • Download URL: dataskipper_boat-1.0.1.tar.gz
  • Upload date:
  • Size: 28.2 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.10.0

File hashes

Hashes for dataskipper_boat-1.0.1.tar.gz
Algorithm Hash digest
SHA256 2fd5f65d01d12e3b3d7afd1bedb907bc2ecb9c8b9d3b180c44a9a28620a4c7a8
MD5 3c1cb3c6ab57543bbd9c7b77103cd21a
BLAKE2b-256 4e7cf71180de98688b274a5fc4f6b7fbeb1a1d8f088ebd2561f96d42d372614a

See more details on using hashes here.

File details

Details for the file dataskipper_boat-1.0.1-py3-none-any.whl.

File metadata

File hashes

Hashes for dataskipper_boat-1.0.1-py3-none-any.whl
Algorithm Hash digest
SHA256 e063a481d18cda6a1513781a7ab58c7461f8413419ba38e0955466615e1d9451
MD5 234714137f4be5e80d8aa667cbce6125
BLAKE2b-256 cc04e6fa84f7fb47623a275f7706afac200326ae6ce9f347fe6a282ab39f6602

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page