RPCPublisherSink

Class Arguments

Argument	Type	Default Value
rpc_publisher	Component
topic_prefix	TStr
default_topic	TStr	newData

Bold arguments are mandatory. For more documentation on the listed arguments refer to the class definition below. If parameters appear in this list but not in the class definition below, please recursively check the linked base classes for the definition of the parameter.

Inheritance Diagram

Example Component Dictionary

   {
    "datasink_example": {
        "classname": "atomiq.components.basics.datasink.RPCPublisherSink",
        "arguments": {
            "rpc_publisher": "<mandatory parameter (Component)>",
            "topic_prefix": "",
            "default_topic": "newData"
        }
    }
}

Class Description

class atomiq.components.basics.datasink.RPCPublisherSink(rpc_publisher, topic_prefix='', default_topic='newData', *args, **kwargs)

Bases: DataSink

Represent a data sink that calls an RPC to publish data. What happens to the data strongly depends on the other end of the RPC, i.e. the service that handles the RPC. Examples could be writing to a pubsub service or dumping to a database.

Parameters:

• rpc_publisher (Component) -- (Component) an RPC device that can handle the function publish()

• topic_prefix (TStr)

• default_topic (TStr)