Skip to main content

Interprocess Communication (IPC) Manager to help create a Command structure for sending and receiving messages between processes.

Project description

Interprocess Communication (IPC) Manager to help create a Command structure for sending and receiving messages between processes.

Simple Listener/Client

# main.py
import ipc_mngr

def msg_handler(sock, cmd):
    """Handle received commands.

    Args:
        sock (multiprocessing.connection.Client): Client socket that received the command.
        cmd (object): Command object that was received.
    """
    print('Received Command:', cmd)

listener = ipc_mngr.Listener(('127.0.0.1', 8111), authkey='12345')
listener.msg_handler = msg_handler
print("listening ...")
listener.listen()  # Listen forever
# send_cmd.py
import ipc_mngr

with ipc_mngr.Client(('127.0.0.1', 8111), authkey='12345') as client:
    # Send the command
    client.send("Hello World!")

Schedule Example

See tests/schedule_run directory for how to use this as a permanent job scheduler.

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

ipc_mngr-0.0.2.tar.gz (8.9 kB view hashes)

Uploaded source

Supported by

AWS AWS Cloud computing Datadog Datadog Monitoring Facebook / Instagram Facebook / Instagram PSF Sponsor Fastly Fastly CDN Google Google Object Storage and Download Analytics Huawei Huawei PSF Sponsor Microsoft Microsoft PSF Sponsor NVIDIA NVIDIA PSF Sponsor Pingdom Pingdom Monitoring Salesforce Salesforce PSF Sponsor Sentry Sentry Error logging StatusPage StatusPage Status page