SQSWatcher#

class langchain_mongodb_deepagents_vfs.watcher.sqs.SQSWatcher(store: ObjectStoreBackend, chunker: Chunker, embedder: Embedder, collection: Collection, queue_url: str, region_name: str | None = None, visibility_timeout: int = 120, endpoint_url: str | None = None, prefix: str = '')[source]#

Event-driven watcher backed by an SQS queue of S3 event notifications.

Parameters:

  • store (ObjectStoreBackend) – Object store backend.

  • chunker (Chunker) – Chunker instance.

  • embedder (Embedder) – Embedder instance.

  • collection (Collection) – MongoDB collection.

  • queue_url (str) – Full SQS queue URL.

  • region_name (str | None) – AWS region.

  • visibility_timeout (int) – How long (seconds) a received message stays invisible to other consumers while being processed.

  • endpoint_url (str | None) – Override for local testing (e.g. LocalStack).

  • prefix (str) – Only ingest keys under this S3 prefix. Events for keys outside it are discarded, so a queue subscribed to a whole shared bucket cannot pull out-of-scope objects into the search index.

Methods

__init__(store, chunker, embedder, ...[, ...])

on_created(key)

Handle a new object in S3.

on_deleted(key)

Handle a deleted object — remove all its chunks from MongoDB.

on_updated(key)

Handle an updated object in S3.

start()

Start the watcher in a background daemon thread.

stop()

Signal the watcher to stop and join the background thread.
__init__(store: ObjectStoreBackend, chunker: Chunker, embedder: Embedder, collection: Collection, queue_url: str, region_name: str | None = None, visibility_timeout: int = 120, endpoint_url: str | None = None, prefix: str = '') → None[source]#
Parameters:

  • store (ObjectStoreBackend)

  • chunker (Chunker)

  • embedder (Embedder)

  • collection (Collection)

  • queue_url (str)

  • region_name (str | None)

  • visibility_timeout (int)

  • endpoint_url (str | None)

  • prefix (str)

Return type:

None

on_created(key: str) → None#

Handle a new object in S3.

Parameters:

key (str)

Return type:

None

on_deleted(key: str) → None#

Handle a deleted object — remove all its chunks from MongoDB.

Parameters:

key (str)

Return type:

None

on_updated(key: str) → None#

Handle an updated object in S3.

Parameters:

key (str)

Return type:

None

start() → None[source]#

Start the watcher in a background daemon thread.

Return type:

None

stop() → None[source]#

Signal the watcher to stop and join the background thread.

Return type:

None