类 MongoDBSaver

constructor

• new MongoDBSaver(__namedParameters, serde?): MongoDBSaver

• 参数

  • __namedParameters: MongoDBSaverParams
  • 可选 serde: SerializerProtocol

  返回值 MongoDBSaver

checkpointCollectionName

checkpointWritesCollectionName

getTuple

• getTuple(config): Promise<undefined | CheckpointTuple>

• 根据提供的配置从 MongoDB 数据库中检索检查点。如果配置包含 "checkpoint_id" 键，则检索与匹配的线程 ID 和检查点 ID 匹配的检查点。否则，检索给定线程 ID 的最新检查点。

  参数

  • config: RunnableConfig

  返回值 Promise<undefined | CheckpointTuple>

list

• list(config, options?): AsyncGenerator<CheckpointTuple, any, unknown>

• 根据提供的配置从 MongoDB 数据库中检索检查点元组列表。检查点按检查点 ID 降序排序（最新优先）。

  参数

  • config: RunnableConfig
  • 可选 options: CheckpointListOptions

  返回值 AsyncGenerator<CheckpointTuple, any, unknown>

put

• put(config, checkpoint, metadata): Promise<RunnableConfig>

• 将检查点保存到 MongoDB 数据库。检查点与提供的配置及其父配置（如果有）相关联。

  参数

  • config: RunnableConfig
  • checkpoint: Checkpoint<string, string>
  • metadata: CheckpointMetadata

  返回值 Promise<RunnableConfig>

putWrites

• putWrites(config, writes, taskId): Promise<void>

• 将与检查点关联的中间写入保存到 MongoDB 数据库。

  参数

  • config: RunnableConfig
  • writes: PendingWrite<string>[]
  • taskId: string

  返回 Promise<void>