txmongo package

Submodules

txmongo.collection module

class txmongo.collection.Collection(database, name, write_concern=None)[source]

Bases: object

aggregate(pipeline, full_response=False)[source]
count(spec=None, fields=None)[source]
create_index(sort_fields, **kwargs)[source]
database
delete_many(filter)[source]
delete_one(filter)[source]
distinct(key, spec=None)[source]
drop(**kwargs)[source]
drop_index(index_identifier)[source]
drop_indexes()[source]
ensure_index(sort_fields, **kwargs)[source]
filemd5(spec)[source]
find(spec=None, skip=0, limit=0, fields=None, filter=None, cursor=False, **kwargs)[source]
find_and_modify(query=None, update=None, upsert=False, **kwargs)[source]
find_one(spec=None, fields=None, **kwargs)[source]
find_one_and_delete(filter, projection=None, sort=None, **kwargs)[source]
find_one_and_replace(filter, replacement, projection=None, sort=None, upsert=False, return_document=False, **kwargs)[source]
find_one_and_update(filter, update, projection=None, sort=None, upsert=False, return_document=False, **kwargs)[source]
find_with_cursor(spec=None, skip=0, limit=0, fields=None, filter=None, **kwargs)[source]

find method that uses the cursor to only return a block of results at a time. Arguments are the same as with find() returns deferred that results in a tuple: (docs, deferred) where docs are the current page of results and deferred results in the next tuple. When the cursor is exhausted, it will return the tuple ([], None)

full_name
group(keys, initial, reduce, condition=None, finalize=None)[source]
index_information()[source]
insert(docs, safe=None, flags=0, **kwargs)[source]
insert_many(documents, ordered=True)[source]
insert_one(document)[source]
map_reduce(map, reduce, full_response=False, **kwargs)[source]
name
options()[source]
remove(spec, safe=None, single=False, flags=0, **kwargs)[source]
rename(new_name)[source]
replace_one(filter, replacement, upsert=False)[source]
save(doc, safe=None, **kwargs)[source]
update(spec, document, upsert=False, multi=False, safe=None, flags=0, **kwargs)[source]
update_many(filter, update, upsert=False)[source]
update_one(filter, update, upsert=False)[source]
with_options(**kwargs)[source]

Get a clone of collection changing the specified settings.

write_concern

txmongo.connection module

class txmongo.connection.ConnectionPool(uri='mongodb://127.0.0.1:27017', pool_size=1, ssl_context_factory=None, **kwargs)[source]

Bases: object

authenticate(database, username, password, mechanism='DEFAULT')[source]
disconnect()[source]
get_default_database()[source]
getprotocol()[source]
getprotocols()[source]
uri
write_concern
class txmongo.connection.MongoConnection(host='127.0.0.1', port=27017, pool_size=1, **kwargs)[source]

Bases: txmongo.connection.ConnectionPool

txmongo.connection.MongoConnectionPool

alias of MongoConnection

txmongo.connection.lazyMongoConnection

alias of MongoConnection

txmongo.connection.lazyMongoConnectionPool

alias of MongoConnection

txmongo.database module

class txmongo.database.Database(factory, database_name, write_concern=None)[source]

Bases: object

authenticate(name, password, mechanism='DEFAULT')[source]

Send an authentication command for this database. mostly stolen from pymongo

collection_names()[source]
command(command, value=1, check=True, allowable_errors=None, **kwargs)[source]
connection
create_collection(name, options=None)[source]
drop_collection(name_or_collection)[source]
name
write_concern

txmongo.filter module

txmongo.filter.ASCENDING(keys)[source]

Ascending sort order

txmongo.filter.DESCENDING(keys)[source]

Descending sort order

txmongo.filter.GEO2D(keys)[source]

Two-dimensional geospatial index http://www.mongodb.org/display/DOCS/Geospatial+Indexing

txmongo.filter.GEO2DSPHERE(keys)[source]

Two-dimensional geospatial index http://www.mongodb.org/display/DOCS/Geospatial+Indexing

txmongo.filter.GEOHAYSTACK(keys)[source]

Bucket-based geospatial index http://www.mongodb.org/display/DOCS/Geospatial+Haystack+Indexing

class txmongo.filter.comment(comment)[source]

Bases: txmongo.filter._QueryFilter

class txmongo.filter.explain[source]

Bases: txmongo.filter._QueryFilter

Returns an explain plan for the query.

class txmongo.filter.hint(index_list_or_name)[source]

Bases: txmongo.filter._QueryFilter

Adds a hint, telling Mongo the proper index to use for the query.

class txmongo.filter.snapshot[source]

Bases: txmongo.filter._QueryFilter

class txmongo.filter.sort(key_list)[source]

Bases: txmongo.filter._QueryFilter

Sorts the results of a query.

txmongo.gridfs module

txmongo.protocol module

Low level connection to Mongo.

This module contains the wire protocol implementation for txmongo. The various constants from the protocol are available as constants.

This implementation requires pymongo so that as much of the implementation can be shared. This includes BSON encoding and decoding as well as Exception types, when applicable.

class txmongo.protocol.Delete[source]

Bases: txmongo.protocol.Delete

class txmongo.protocol.Getmore[source]

Bases: txmongo.protocol.Getmore

class txmongo.protocol.Insert[source]

Bases: txmongo.protocol.Insert

class txmongo.protocol.KillCursors[source]

Bases: txmongo.protocol.KillCursors

exception txmongo.protocol.MongoAuthenticationError[source]

Bases: Exception

class txmongo.protocol.MongoClientProtocol[source]

Bases: twisted.internet.protocol.Protocol

get_request_id()[source]
send(request)[source]
send_DELETE(request)[source]
send_GETMORE(request)[source]
send_INSERT(request)[source]
send_KILL_CURSORS(request)[source]
send_MSG(request)[source]
send_QUERY(request)[source]
send_REPLY(request)[source]
send_UPDATE(request)[source]
class txmongo.protocol.MongoDecoder[source]

Bases: object

dataBuffer = None
static decode(message_data)[source]
feed(data)[source]
next()
class txmongo.protocol.MongoProtocol[source]

Bases: txmongo.protocol.MongoServerProtocol, txmongo.protocol.MongoClientProtocol

authenticate(database_name, username, password, mechanism)[source]
authenticate_mongo_cr(database_name, username, password)[source]
authenticate_scram_sha1(database_name, username, password)[source]
connectionLost(reason=<twisted.python.failure.Failure twisted.internet.error.ConnectionDone: Connection was closed cleanly.>)[source]
connectionMade()[source]
connectionReady()[source]
fail(reason)[source]
get_last_error(db, **options)[source]
handle_REPLY(request)[source]
inflight()[source]
max_wire_version = None
min_wire_version = None
send_GETMORE(request)[source]
send_QUERY(request)[source]
set_wire_versions(min_wire_version, max_wire_version)[source]
class txmongo.protocol.MongoServerProtocol[source]

Bases: twisted.internet.protocol.Protocol

dataReceived(data)[source]
handle(request)[source]
handle_DELETE(request)[source]
handle_GETMORE(request)[source]
handle_INSERT(request)[source]
handle_KILL_CURSORS(request)[source]
handle_MSG(request)[source]
handle_QUERY(request)[source]
handle_REPLY(request)[source]
handle_UPDATE(request)[source]
class txmongo.protocol.Msg(len, request_id, response_to, opcode, message)

Bases: tuple

len

Alias for field number 0

message

Alias for field number 4

opcode

Alias for field number 3

request_id

Alias for field number 1

response_to

Alias for field number 2

class txmongo.protocol.Query[source]

Bases: txmongo.protocol.Query

class txmongo.protocol.Reply[source]

Bases: txmongo.protocol.Reply

class txmongo.protocol.Update[source]

Bases: txmongo.protocol.Update

Module contents