+ Bi IRt^RIt^RIt^RIt^RIt^RIt^RIHtHt^RIH t ^RI H t H t H t ^RIHtHtHtHtHtHt!RR] 4t!RR ]4t!R R 4t!R R 4t!RR4tRtR#)zDGridFS implementation for Motor, an asynchronous driver for MongoDB.N)DEFAULT_CHUNK_SIZE grid_file) docstrings)AgnosticCollectionAgnosticCursorAgnosticDatabase) AsyncCommand AsyncReadDelegateMethodReadOnlyPropertycoroutine_annotationcreate_class_with_frameworkcNaa]tRt^$toRt]P tV3RltRt Vt V;t #)AgnosticGridOutCursorMotorGridOutCursorc <\SV`4pV'd:\\VPVP 4pV!VP VR7#R#)z5**DEPRECATED** - Get next GridOut object from cursor.)delegateN)super next_objectr AgnosticGridOut _framework __module__ collection)selfgrid_outgrid_out_class __class__s& P/var/www/html/photoedit/myenv/lib/python3.14/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____classdictcell__ __classcell__)r __classdict__s@@rrr$s!/--  rrc*a]tRt^7toRtRtRtVtR#)MotorGridOutPropertyz.fget;sJ<<%%%nn55&(12 3<<3 3r)r9doc)r6r'__doc__property)rclsr8r9r;s&&f rcreate_attribute%MotorGridOutProperty.create_attribute:s- 4c,,i8@@T++rr N)r!rr"r#r<r?r(r)r+s@rr-r-7sF , ,rr-ca]tRt^HtoRtRt]Pt] !4t ] !4t ] !4t ] !4t ] !4t] !4t] !4t] !4t] !4t]!RR7t]!4t]!4t]!4t]!4t]!4t]!4t]!4t] !4t]!4tRRlt Rt!Rt"R t#]$R 4t%R t&R t'R t(Vt)R#)raClass 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)r8Nc$\\VPVP4p\ W4'g\ RV,4hV'dW@nM#VPVP W#VR7VnVP4Vn R#)z>First argument to MotorGridOut must be MotorCollection, not %r)sessionN) r rrr isinstance TypeErrorrr' get_io_loopio_loop)rroot_collectionfile_id file_documentrrFcollection_classs&&&&&& r__init__AgnosticGridOut.__init__ls7  /<<*,;<  $M 33((''4DM'224 rcV#Nr rs&r __aiter__AgnosticGridOut.__aiter__s rcf"VP4GRjxL pV'dV#\4hL5irR) readchunkStopAsyncIteration)rchunks& r __anext__AgnosticGridOut.__anext__s*nn&& L ""'s1/ 1 1cVPP'g'\PP RV,4h\ VPV4#r0r1)ritems&&r __getattr__AgnosticGridOut.__getattr__sE}}"""..11TW[[ t}}d++rc tVPPVP4VP4V4#)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_openrIrSs&rrDAgnosticGridOut.opens-11$**,@P@P@RTXYYrcVP#rRrJrSs&rrIAgnosticGridOut.get_io_loop ||rc "^pW P8dYVPVP4GRjxL pVPV4VP 4V\ V4, pKhR#L;5i)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 `_ N)lengthread chunk_sizewriteflushlen)rrequest_handlerwrittenrYs&& rstream_to_handler!AgnosticGridOut.stream_to_handlers]8 #))DOO44E  ! !% (  ! ! # s5z !G$4s1A1A/`_ 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 %rrFN) r rrrrGrHrIrJr'r)rrKrrFkwargsrNs&&&&, rrOAgnosticGridIn.__init__sV7  /<<ORaa '224    D$;$;  $ $% .5% 9?%  rc"V#5irRr rSs&r __aenter__AgnosticGridIn.__aenter__0s  scF"VPWV4GRjxL R#L5irR)_exit)rexc_typeexc_valexc_tbs&&&&r __aexit__AgnosticGridIn.__aexit__3sjjF333s !!cVP#rRrerSs&rrIAgnosticGridIn.get_io_loop6rgrrs)NN)%r!rr"r#r$r%GridInr'r r^r rurabortrkclosedrwrxryrir{rjr|rrunwraprl writeable writelinesrsetrOrrrIr(r)rAs@rrrs( "K  C NE!#J  F NE#%L!H  F  D  DHH"$K N ! !. 1E I&&~6J  $E   C$8 v4rrca]tRtRtoRt]P t]!] PR7t ]!] PR7t ]!] PR7t]!] P R7P#]P$4t]!] P(R7P#]P$4t]!] P.R7P#]P04t]!] P4R7P#]P04t]!] P8R7t]!] P<R7t]!] P@R7t!R]"RRR3Rlt#Rt$RtR t%R t&Vt'R#) AgnosticGridFSBucketi:MotorGridFSBucket)r;fsNc Ve \P!R\^R7Tp\\VP VP 4p\W4'g\RVP RV: 24hVP4Vn VPW$VR7Vn VPVPVVVVR7VnR#)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)warningswarnDeprecationWarningr rrrrGrHrrIrJget_collectionrr'r)rdatabase bucket_namerrrrdb_classs&&&&&&& rrOAgnosticGridFSBucket.__init__QsX  ! MMU"  %K./?RVRaRab(--$T^^$44QRZQ]^  ++- "11 o2 //    -'+ 0  rcVP#rRrerSs&rrI AgnosticGridFSBucket.get_io_looprgrcVP\PJd:\\VP VP 4pV!VPVR7#VP\PJd:\\VP VP 4pV!VPVR7#VP\PJd9\\VP VP 4pV!WPR7#R#))rKr)cursorrN) rrrr rrrrrtrr%r&r)rr7 grid_in_classrs&& rwrapAgnosticGridFSBucket.wraps ==I,, ,7M!3O O ]]i// /8$//N"$//CP P ]]f22 28%tN"I I 3rc VPP!V/VBp\\VPVP 4pV!W0P 4#)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. )rfindr rrrr)rargsrrgrid_out_cursors&*, rrAgnosticGridFSBucket.findsHj##T4V45 !4??DOO v77r)rrrJ)(r!rr"r#r$r% GridFSBucketr'rrgridfs_delete_docdeletegridfs_download_to_stream_docdownload_to_stream%gridfs_download_to_stream_by_name_docdownload_to_stream_by_namegridfs_open_download_stream_docrrtopen_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_idrrOrIrr(r)rAs@rrr:s>.,, j:: ;F%**R*RS!-*2b2b!c'J,V,VW\\$0  > >$ d6>>!(J,T,TUZZ "0  < <" d6==j:: ;F%**R*RS!-*2b2b!c +E NJ,:8:8rrc^\P!\VP4P R44pVP \VP 4P R44VP \VP4P R44VP4#)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) hashlibsha256strruencodeupdaterir hexdigest)gridout grid_hashs& r _hash_gridoutrs{s7;;/66v>?I S(//78 S,,-44V<=     r)r<rrr%r3pymongo.errorsrrmotorr motor.corerrrmotor.metaprogrammingrr r r r r rr-rrrrr rrrsuK 0KKN&,+,"B"B"JjjZq8q8h !r