Class MemorystoreDocumentLoader (0.3.0) 

MemorystoreDocumentLoader(
    client: typing.Union[redis.client.Redis, redis.cluster.RedisCluster],
    key_prefix: str,
    content_fields: typing.Set[str],
    metadata_fields: typing.Optional[typing.Set[str]] = None,
    batch_size: int = 100,
)

Document Loader for Cloud Memorystore for Redis database.

Methods

MemorystoreDocumentLoader

MemorystoreDocumentLoader(
    client: typing.Union[redis.client.Redis, redis.cluster.RedisCluster],
    key_prefix: str,
    content_fields: typing.Set[str],
    metadata_fields: typing.Optional[typing.Set[str]] = None,
    batch_size: int = 100,
)

Initializes the Document Loader for Memorystore for Redis.

_construct_document

_construct_document(stored_value) -> langchain_core.documents.base.Document

Construct a Document from stored value.

_decode_if_json_parsable

_decode_if_json_parsable(s: str) -> typing.Union[str, dict]

Decode a JSON string to a dict if it is JSON.

lazy_load

lazy_load() -> typing.Iterator[langchain_core.documents.base.Document]

Lazy load the Documents and yield them one by one.

load

load() -> typing.List[langchain_core.documents.base.Document]

Load all Documents using a Redis pipeline for efficiency.