API文档¶

class sqlalchemy.ext.horizontal_shard.ShardedSession(shard_chooser, id_chooser, query_chooser, shards=None, query_cls=<class 'sqlalchemy.ext.horizontal_shard.ShardedQuery'>, **kwargs)¶

基础：sqlalchemy.orm.session.Session

__init__(shard_chooser, id_chooser, query_chooser, shards=None, query_cls=<class 'sqlalchemy.ext.horizontal_shard.ShardedQuery'>, **kwargs)¶

构建ShardedSession。

参数：

shard_chooser¶ – A callable which, passed a Mapper, a mapped instance, and possibly a SQL clause, returns a shard ID. 该ID可以基于对象内存在的属性或某种循环方案。如果该方案基于选择，则应设置实例上的任何状态以将其标记为参与该分片。 id_chooser¶ – A callable, passed a query and a tuple of identity values, which should return a list of shard ids where the ID might reside. 数据库将按照此列表的顺序进行查询。 query_chooser¶ – For a given Query, returns the list of shard_ids where the query should be issued. 所有返回的碎片结果将合并成一个列表。 shards¶ – A dictionary of string shard names to Engine objects.

class sqlalchemy.ext.horizontal_shard.ShardedQuery(*args, **kwargs)¶

基础：sqlalchemy.orm.query.Query

set_shard T0> （ T1> shard_id T2> ） T3> ¶ T4>

返回一个新的查询，限于单个分片ID。

无论其他状态如何，返回查询的所有后续操作都将针对单个分片。