btnexus-node-python.btStreamingNode module

A Node which accepts audio streams and forwards them to the speech to text service of your choice and publishes the transcript on the transcript topic

class btStreamingNode.StreamingNode(language=None, personalityId=None, integrationId=None, sessionId=None, **kwargs)

Bases: btNode.Node

Constructor sets up the NexusConnector.

Parameters

• token (String) – AccessToken for the btNexus

• axonURL (String) – URL for the Axon(InstanceURL)

• debug (bool) – switch for debug messages

• logger (Logger) – a logger object to log to

• personalityId (String) – Id of your Personality

• integrationId (String) – Id of the integration this Node belongs to

connect(**kwargs)

connect the Axon and start the reactor for twisted. This will always block because of the reactor pattern

getSessionId()

return the sessionId this needs to be implemented for a service node

handshake()

Do the Handshake with the Service and retry until it works.

onStreamReady()

Start your stream with self.stream(stream) - this will stream data from the given stream to the SpeechService.

setSessionId(response)

callback for the sessionAccessRequest

stream(stream)

This takes a stream and streams it to the Service

streamTo(host, port)

This reacts to the message from the Service telling where to connect to with twisted.