Version: 3.x
rasa.core.brokers.sql
SQLEventBroker Objects
class SQLEventBroker(EventBroker)
Save events into an SQL database.
All events will be stored in a table called events
.
SQLBrokerEvent Objects
class SQLBrokerEvent(Base)
ORM which represents a row in the events
table.
__init__
def __init__(dialect: Text = "sqlite",
host: Optional[Text] = None,
port: Optional[int] = None,
db: Text = "events.db",
username: Optional[Text] = None,
password: Optional[Text] = None) -> None
Initializes SQLBrokerEvent
.
from_endpoint_config
@classmethod
async def from_endpoint_config(
cls,
broker_config: EndpointConfig,
event_loop: Optional[AbstractEventLoop] = None) -> "SQLEventBroker"
Creates broker. See the parent class for more information.
session_scope
@contextlib.contextmanager
def session_scope() -> Generator[Session, None, None]
Provide a transactional scope around a series of operations.
publish
def publish(event: Dict[Text, Any]) -> None
Publishes a json-formatted Rasa Core event into an event queue.