Class AlloyDBEngine (0.4.0)

AlloyDBEngine(
    engine: sqlalchemy.ext.asyncio.engine.AsyncEngine,
    loop: typing.Optional[asyncio.events.AbstractEventLoop],
    thread: typing.Optional[threading.Thread],
)

A class for managing connections to a AlloyDB database.

Methods

_aexecute

_aexecute(query: str, params: typing.Optional[dict] = None) -> None

Execute a SQL query.

_aexecute_outside_tx

_aexecute_outside_tx(query: str) -> None

Execute a SQL query.

_aload_table_schema

_aload_table_schema(table_name: str) -> sqlalchemy.sql.schema.Table

Load table schema from existing table in PgSQL database.

Returns
Type	Description
`(sqlalchemy.Table)`	The loaded table.

ainit_document_table

ainit_document_table(
    table_name: str,
    content_column: str = "page_content",
    metadata_columns: typing.List[
        langchain_google_alloydb_pg.alloydb_engine.Column
    ] = [],
    metadata_json_column: str = "langchain_metadata",
    store_metadata: bool = True,
) -> None

Create a table for saving of langchain documents.

Parameters
Name	Description
`table_name`	`str` The PgSQL database table name.
`metadata_columns`	`List[Column]` A list of Columns to create for custom metadata. Optional.
`store_metadata`	`bool` Whether to store extra metadata in a metadata column if not described in 'metadata' field list (Default: True).