rpc_client_raw.py

import os

from twisted.internet.endpoints import TCP4ClientEndpoint
from twisted.internet.defer import inlineCallbacks
from twisted.internet.task import react
from twisted.spread.pb import Broker, PBClientFactory, RemoteReference


class MyPBClientFactory(PBClientFactory):
    def __init__(self):
        super().__init__()

    def clientConnectionMade(self, broker: Broker):
        print("RAW client connected.")
        super().clientConnectionMade(broker)


@react
@inlineCallbacks
def main(reactor):
    local_endpoint: TCP4ClientEndpoint = TCP4ClientEndpoint(
        reactor,
        os.environ.get('SERVER_HOST'),
        int(os.environ.get('SERVER_PORT')))

    client_factory: MyPBClientFactory = MyPBClientFactory()
    _: Broker = yield local_endpoint.connect(client_factory)

    root: RemoteReference = yield client_factory.getRootObject()
    data: str = yield root.callRemote("echo", "HELLO RAW!")

    print(f"Server echoed: {data}")