from pynats import NATSClient from a2s.tools import json_serialize def safe_logout(): with NATSClient("nats://172.17.4.188:19090") as nc: nc.connect() nc.publish(subject="monitorRelease", payload=json_serialize({"host": "ai-01"})) safe_logout()