9h ISrSSKrSSKrSSKrSSKrSSKrSSKJrJr SSKJ r SSK J r J r J r SSKJrJrJrJrJrJr "SS\ 5r"S S \5r"S S 5r"S S5r"SS5rSrg)zDGridFS implementation for Motor, an asynchronous driver for MongoDB.N)DEFAULT_CHUNK_SIZE grid_file) docstrings)AgnosticCollectionAgnosticCursorAgnosticDatabase) AsyncCommand AsyncReadDelegateMethodReadOnlyPropertycoroutine_annotationcreate_class_with_frameworkcD^\rSrSrSr\R rU4SjrSr U=r $)AgnosticGridOutCursor$MotorGridOutCursorc>[TU]5nU(a6[[URUR 5nU"UR US9$g)z5**DEPRECATED** - Get next GridOut object from cursor.)delegateN)super next_objectrAgnosticGridOut _framework __module__ collection)selfgrid_outgrid_out_class __class__s WC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\motor/motor_gridfs.pyr!AgnosticGridOutCursor.next_object(sF7&( 8$//N"$//HE E) __name__r __qualname____firstlineno____motor_class_name__gridfs GridOutCursor__delegate_class__r__static_attributes__ __classcell__)rs@rrr$s/--  r!rc\rSrSrSrSrSrg)MotorGridOutProperty7zURR(d"[RR ST-5e[ URT5$NzBYou must call MotorGridOut.open() before accessing the %s propertyr_filepymongoerrorsInvalidOperationgetattr)obj attr_names rfget3MotorGridOutProperty.create_attribute..fget;sG<<%%nn55&(12 3<<3 3r!)r:doc)r7r)__doc__property)rclsr9r:r<s ` rcreate_attribute%MotorGridOutProperty.create_attribute:s- 4c,,i8@@T++r!r"N)r#rr$r%r=r@r*r"r!rr-r-7s F ,r!r-cv\rSrSrSrSr\Rr\ "5r \ "5r \ "5r \ "5r \ "5r\ "5r\ "5r\ "5r\ "5r\"SS9r\"5r\"5r\"5r\"5r\"5r\"5r\"5r\ "5r\"5rSSjr Sr!S r"S r#\$S 5r%S r&S r'Sr(g)rHaClass to read data out of GridFS. MotorGridOut supports the same attributes as PyMongo's :class:`~gridfs.grid_file.GridOut`, such as ``_id``, ``content_type``, etc. You don't need to instantiate this class directly - use the methods provided by :class:`~motor.MotorGridFSBucket`. If it **is** instantiated directly, call :meth:`open`, :meth:`read`, or :meth:`readline` before accessing its attributes. MotorGridOutopen)r9Nc[[URUR5n[ X5(d[ SU-5eU(aX@lO URUR X#US9UlUR5Ul g)Nz>First argument to MotorGridOut must be MotorCollection, not %r)session) rrrr isinstance TypeErrorrr) get_io_loopio_loop)rroot_collectionfile_id file_documentrrGcollection_classs r__init__AgnosticGridOut.__init__ls7  /<<*,;<  $M 33((''4DM'224 r!cU$Nr"rs r __aiter__AgnosticGridOut.__aiter__s r!cd# UR5IShvN nU(aU$[5eN7frS) readchunkStopAsyncIteration)rchunks r __anext__AgnosticGridOut.__anext__s*nn&& L ""'s 0.0cURR(d"[RR SU-5e[ URU5$r1r2)ritems r __getattr__AgnosticGridOut.__getattr__sB}}""..11TW[[ t}}d++r!ctURRUR5UR5U5$)a Retrieve this file's attributes from the server. Returns a Future. .. versionchanged:: 2.0 No longer accepts a callback argument. .. versionchanged:: 0.2 :class:`~motor.MotorGridOut` now opens itself on demand, calling ``open`` explicitly is rarely needed. )rchain_return_value_openrJrTs rrEAgnosticGridOut.opens-11$**,@P@P@RTXYYr!cUR$rSrKrTs rrJAgnosticGridOut.get_io_loop ||r!c# SnX R:adURUR5IShvN nURU5 UR 5 U[ U5- nX R:aMcggNF7f)aWrite the contents of this file to a :class:`tornado.web.RequestHandler`. This method calls :meth:`~tornado.web.RequestHandler.flush` on the RequestHandler, so ensure all headers have already been set. For a more complete example see the implementation of :class:`~motor.web.GridFSHandler`. .. code-block:: python class FileHandler(tornado.web.RequestHandler): @tornado.web.asynchronous @gen.coroutine def get(self, filename): db = self.settings["db"] fs = await motor.MotorGridFSBucket(db()) try: gridout = await fs.open_download_stream_by_name(filename) except gridfs.NoFile: raise tornado.web.HTTPError(404) self.set_header("Content-Type", gridout.content_type) self.set_header("Content-Length", gridout.length) await gridout.stream_to_handler(self) self.finish() .. seealso:: Tornado `RequestHandler `_ rN)lengthread chunk_sizewriteflushlen)rrequest_handlerwrittenrZs rstream_to_handler!AgnosticGridOut.stream_to_handlersd8 #))DOO44E  ! !% (  ! ! # s5z !G #4s0A;A9AA;7A;rrK)NNNN))r#rr$r%r=r&r'GridOutr)r-_idaliasesrlclose content_typefilenamerjmetadatanamer rcr rkr readablerXreadlineseekseekabletell upload_datermrPrUr[r_r rErJrrr*r"r!rrrHs *  C"$G%'J "E')L#%H ! #F#%H  !D 6 *E ;DH I{H  DH  D&(K  EY]5,# , Z Z%"r!rc\rSrSrSr\R r\"5r \ "5r \ "5r \ "5r\ "5r\ "5r\ "5r\ "5r\ "5r\ "5r\"5r\"5r\"5r\ "5r\ "5R3S5r\"5r\ "5R3S5r\ "S5r\ "SSS9rSS jrS r S r!S r"S r#g)AgnosticGridIn MotorGridInrD__exit__ __setattr__a Set an arbitrary metadata attribute on the file. Stores value on the server as a key-value pair within the file document once the file is closed. If the file is already closed, calling :meth:`set` will immediately update the file document on the server. Metadata set on the file appears as attributes on a :class:`~motor.MotorGridOut` object created from the file. :Parameters: - `name`: Name of the attribute, will be stored as a key in the file document on the server - `value`: Value of the attribute )r9r<Nc [[URUR5n[ X5(d[ SU-5eUR 5UlU=(d UR"UR4SU0UD6Ul g)a Class to write data to GridFS. Application developers should not generally need to instantiate this class - see :meth:`~motor.MotorGridFSBucket.open_upload_stream`. Any of the file level options specified in the `GridFS Spec `_ may be passed as keyword arguments. Any additional keyword arguments will be set as additional fields on the file document. Valid keyword arguments include: - ``"_id"``: unique ID for this file (default: :class:`~bson.objectid.ObjectId`) - this ``"_id"`` must not have already been used for another file - ``"filename"``: human name for the file - ``"contentType"`` or ``"content_type"``: valid mime-type for the file - ``"chunkSize"`` or ``"chunk_size"``: size of each of the chunks, in bytes (default: 256 kb) - ``"encoding"``: encoding used for this file. In Python 2, any :class:`unicode` that is written to the file will be converted to a :class:`str`. In Python 3, any :class:`str` that is written to the file will be converted to :class:`bytes`. :Parameters: - `root_collection`: root collection to write to - `session` (optional): a :class:`~pymongo.client_session.ClientSession` to use for all commands - `**kwargs` (optional): file level options (see above) .. versionchanged:: 3.0 Removed support for the `disable_md5` parameter (to match the GridIn class in PyMongo). .. versionchanged:: 0.2 ``open`` method removed, no longer needed. z=First argument to MotorGridIn must be MotorCollection, not %rrGN) rrrrrHrIrJrKr)r)rrLrrGkwargsrOs rrPAgnosticGridIn.__init__sV7  /<<ORaa '224   D$;$;  $ $% .5% 9?%  r!c# U$7frSr"rTs r __aenter__AgnosticGridIn.__aenter__0s  scD# URXU5IShvN gN7frS)_exit)rexc_typeexc_valexc_tbs r __aexit__AgnosticGridIn.__aexit__3sjjF333s   cUR$rSrfrTs rrJAgnosticGridIn.get_io_loop6rhr!rt)NN)$r#rr$r%r&r'GridInr)r r_r rvr abortrlclosedrxryrzrjr|rkr}rrunwraprm writeable writelinesrsetrPrrrJr*r"r!rrrs( "K  C NE!#J  F NE#%L!H  F  D  DHH"$K N ! !. 1E I&&~6J  $E   C$8 v4r!rc^\rSrSrSr\R r\"\ RS9r \"\ RS9r \"\ RS9r\"\ R S9R#\R$5r\"\ R(S9R#\R$5r\"\ R.S9R#\R05r\"\ R4S9R#\R05r\"\ R8S9r\"\ R<S9r\"\ R@S9r!S\"SSS4Sjr#Sr$SrS r%S r&g) AgnosticGridFSBucketi:MotorGridFSBucket)r<fsNc|Ub[R"S[SS9 Un[[UR UR 5n[X5(d[SURSU<35eUR5Ul URX$US9Ul URURUUUUS9Ulg) a"Create a handle to a GridFS bucket. Raises :exc:`~pymongo.errors.ConfigurationError` if `write_concern` is not acknowledged. This class conforms to the `GridFS API Spec `_ for MongoDB drivers. :Parameters: - `database`: database to use. - `bucket_name` (optional): The name of the bucket. Defaults to 'fs'. - `chunk_size_bytes` (optional): The chunk size in bytes. Defaults to 255KB. - `write_concern` (optional): The :class:`~pymongo.write_concern.WriteConcern` to use. If ``None`` (the default) db.write_concern is used. - `read_preference` (optional): The read preference to use. If ``None`` (the default) db.read_preference is used. - `collection` (optional): Deprecated, an alias for `bucket_name` that exists solely to provide backwards compatibility. .. versionchanged:: 3.0 Removed support for the `disable_md5` parameter (to match the GridFSBucket class in PyMongo). .. versionchanged:: 2.1 Added support for the `bucket_name`, `chunk_size_bytes`, `write_concern`, and `read_preference` parameters. Deprecated the `collection` parameter which is now an alias to `bucket_name` (to match the GridFSBucket class in PyMongo). .. versionadded:: 1.0 .. mongodoc:: gridfs NzCthe "collection" parameter is deprecated, use "bucket_name" instead) stacklevelzFirst argument to z must be MotorDatabase, not ) write_concernread_preference)chunk_size_bytesrr)warningswarnDeprecationWarningrrrrrHrIrrJrKget_collectionrr)r)rdatabase bucket_namerrrrdb_classs rrPAgnosticGridFSBucket.__init__QsX  ! MMU"  %K./?RVRaRab(--$T^^$44QRZQ]^  ++- "11 o2 //    -'+ 0  r!cUR$rSrfrTs rrJ AgnosticGridFSBucket.get_io_looprhr!cUR[RLa6[[UR UR 5nU"URUS9$UR[RLa6[[UR UR 5nU"URUS9$UR[RLa5[[UR UR 5nU"XRS9$g)N)rLr)cursorr) rrrrrrrrrurr'r(r)rr8 grid_in_classrs rwrapAgnosticGridFSBucket.wraps ==I,, ,7M!3O O ]]i// /8$//N"$//CP P ]]f22 28%tN"I I 3r!cURR"U0UD6n[[URUR 5nU"X0R 5$)aFind and return the files collection documents that match ``filter``. Returns a cursor that iterates across files matching arbitrary queries on the files collection. Can be combined with other modifiers for additional control. For example:: cursor = bucket.find({"filename": "lisa.txt"}, no_cursor_timeout=True) while (await cursor.fetch_next): grid_out = cursor.next_object() data = await grid_out.read() This iterates through all versions of "lisa.txt" stored in GridFS. Note that setting no_cursor_timeout to True may be important to prevent the cursor from timing out during long multi-file processing work. As another example, the call:: most_recent_three = fs.find().sort("uploadDate", -1).limit(3) would return a cursor to the three most recently uploaded files in GridFS. Follows a similar interface to :meth:`~motor.MotorCollection.find` in :class:`~motor.MotorCollection`. :Parameters: - `filter`: Search query. - `batch_size` (optional): The number of documents to return per batch. - `limit` (optional): The maximum number of documents to return. - `no_cursor_timeout` (optional): The server normally times out idle cursors after an inactivity period (10 minutes) to prevent excess memory use. Set this option to True prevent that. - `skip` (optional): The number of documents to skip before returning. - `sort` (optional): The order by which to sort results. Defaults to None. - `session` (optional): a :class:`~pymongo.client_session.ClientSession`, created with :meth:`~MotorClient.start_session`. If a :class:`~pymongo.client_session.ClientSession` is passed to :meth:`find`, all returned :class:`MotorGridOut` instances are associated with that session. .. versionchanged:: 1.2 Added session parameter. )rfindrrrrr)rargsrrgrid_out_cursors rrAgnosticGridFSBucket.findsHj##T4V45 !4??DOO v77r!)rrrK)'r#rr$r%r&r' GridFSBucketr)r rgridfs_delete_docdeletegridfs_download_to_stream_docdownload_to_stream%gridfs_download_to_stream_by_name_docdownload_to_stream_by_namegridfs_open_download_stream_docrruopen_download_stream'gridfs_open_download_stream_by_name_docopen_download_stream_by_namer gridfs_open_upload_stream_docropen_upload_stream%gridfs_open_upload_stream_with_id_docopen_upload_stream_with_idgridfs_rename_docrenamegridfs_upload_from_stream_docupload_from_stream%gridfs_upload_from_stream_with_id_docupload_from_stream_with_idrrPrJrr*r"r!rrr:s6.,, j:: ;F%**R*RS!-*2b2b!c'J,V,VW\\$0  > >$ d6>>!(J,T,TUZZ "0  < <" d6==j:: ;F%**R*RS!-*2b2b!c +E NJ,:8r!rc^[R"[UR5R S55nUR [UR 5R S55 UR [UR5R S55 UR5$)zCompute the effective hash of a GridOut object for use with an Etag header. Create a FIPS-compliant Etag HTTP header hash using sha256 We use the _id + length + upload_date as a proxy for uniqueness to avoid reading the entire file. utf8) hashlibsha256strrvencodeupdaterjr hexdigest)gridout grid_hashs r _hash_gridoutrs{s7;;/66v>?I S(//78 S,,-44V<=     r!)r=rrr'r4pymongo.errorsrrmotorr motor.corerrrmotor.metaprogrammingr r r r r rrr-rrrrr"r!rrsuK 0KKN&,+,"B"B"JjjZq8q8h !r!