connectordb/logger.py
def addStream(self, streamname, schema=None, **kwargs):
        """Adds the given stream to the logger. Requires an active connection to the ConnectorDB database.

        If a schema is not specified, loads the stream from the database. If a schema is specified, and the stream
        does not exist, creates the stream. You can also add stream properties such as description or nickname to be added
        during creation."""

        stream = self.connectordb[streamname]

        if not stream.exists():
            if schema is not None:
                stream.create(schema, **kwargs)
            else:
                raise Exception(
                    "The stream '%s' was not found" % (streamname, ))

        self.addStream_force(streamname, stream.schema)
def addStream(self, streamname, schema=None, **kwargs):
        stream = self.connectordb[streamname]

        if not stream.exists():
            if schema is not None:
                stream.create(schema, **kwargs)
            else:
                raise Exception(
                    "The stream '%s' was not found" % (streamname, ))

        self.addStream_force(streamname, stream.schema)
def addStream ( self , streamname , schema = None , * * kwargs ) : stream = self . connectordb [ streamname ] if not stream . exists ( ) : if schema is not None : stream . create ( schema , * * kwargs ) else : raise Exception ( "The stream '%s' was not found" % ( streamname , ) ) self . addStream_force ( streamname , stream . schema )
Adds the given stream to the logger. Requires an active connection to the ConnectorDB database.

        If a schema is not specified, loads the stream from the database. If a schema is specified, and the stream
        does not exist, creates the stream. You can also add stream properties such as description or nickname to be added
        during creation.
Adds the given stream to the logger . Requires an active connection to the ConnectorDB database .