+ Bi$rRt^RIt^RIt^RIt^RIt^RIHtHt^RI H t Rt Rt Rt Rt!RR 4tR#) zServe GridFS files with Motor and aiohttp. Requires Python 3.5 or later and aiohttp 3.0 or later. See the :doc:`/examples/aiohttp_gridfs_example`. N)AsyncIOMotorDatabaseAsyncIOMotorGridFSBucket) _hash_gridoutc$VPV4#)aOverride to choose a GridFS file to serve at a URL. By default, if a URL pattern like ``/fs/{filename}`` is mapped to this :class:`AIOHTTPGridFS`, then the filename portion of the URL is used as the filename, so a request for "/fs/image.png" results in a call to :meth:`.AsyncIOMotorGridFSBucket.open_download_stream_by_name` with "image.png" as the ``filename`` argument. To customize the mapping of path to GridFS file, override ``get_gridfs_file`` and return a :class:`asyncio.Future` that resolves to a :class:`~motor.motor_asyncio.AsyncIOMotorGridOut`. For example, to retrieve the file by ``_id`` instead of filename:: def get_gridfile_by_id(bucket, filename, request): # "filename" is interpreted as _id instead of name. # Return a Future AsyncIOMotorGridOut. return bucket.open_download_stream(file_id=filename) client = AsyncIOMotorClient() gridfs_handler = AIOHTTPGridFS(client.my_database, get_gridfs_file=get_gridfile_by_id) :Parameters: - `bucket`: An :class:`~motor.motor_asyncio.AsyncIOMotorGridFSBucket` - `filename`: A string, the URL portion matching {filename} in the URL pattern - `request`: An :class:`aiohttp.web.Request` )open_download_stream_by_name)bucketfilenamerequests&&&T/var/www/html/photoedit/myenv/lib/python3.14/site-packages/motor/aiohttp/__init__.pyget_gridfs_filer "s<  . .x 88c^#)aOverride to customize cache control behavior. Return a positive number of seconds to trigger aggressive caching or 0 to mark resource as cacheable, only. 0 is the default. For example, to allow image caching:: def image_cache_time(filename, modified, mime_type): if mime_type.startswith('image/'): return 3600 return 0 client = AsyncIOMotorClient() gridfs_handler = AIOHTTPGridFS(client.my_database, get_cache_time=image_cache_time) :Parameters: - `filename`: A string, the URL portion matching {filename} in the URL pattern - `modified`: A datetime, when the matching GridFS file was created - `mime_type`: The file's type, a string like "application/octet-stream" )rmodified mime_types&&&r get_cache_timerCs0 r cR#)aOverride to modify the response before sending to client. For example, to allow image caching:: def gzip_header(response, gridout): response.headers['Content-Encoding'] = 'gzip' client = AsyncIOMotorClient() gridfs_handler = AIOHTTPGridFS(client.my_database, set_extra_headers=gzip_header) :Parameters: - `response`: An :class:`aiohttp.web.Response` - `gridout`: The :class:`~motor.motor_asyncio.AsyncIOMotorGridOut` we will serve to the client Nr)responsegridouts&&r set_extra_headersr^sr cVPPPP4R,pRV,p\ PPVR7Rh \\ 3d RT,pL=i;i) formatterz>@M LyX ++ - -3 - 7TA n %B7'ABs>A!!A>=A>cBa]tRt^|toRtR]]]3RltRt Rt Rt Vt R#) AIOHTTPGridFSaServe files from `GridFS`_. This class is a :ref:`request handler ` that serves GridFS files, similar to aiohttp's built-in static file server. .. code-block:: python client = AsyncIOMotorClient() gridfs_handler = AIOHTTPGridFS(client.my_database) app = aiohttp.web.Application() # The GridFS URL pattern must have a "{filename}" variable. resource = app.router.add_resource("/fs/{filename}") resource.add_route("GET", gridfs_handler) resource.add_route("HEAD", gridfs_handler) app_handler = app.make_handler() server = loop.create_server(app_handler, port=80) By default, requests' If-Modified-Since headers are honored, but no specific cache-control timeout is sent to clients. Thus each request for a GridFS file requires a quick check of the file's ``uploadDate`` in MongoDB. Pass a custom :func:`get_cache_time` to customize this. :Parameters: - `database`: An :class:`AsyncIOMotorDatabase` - `get_gridfs_file`: Optional override for :func:`get_gridfs_file` - `get_cache_time`: Optional override for :func:`get_cache_time` - `set_extra_headers`: Optional override for :func:`set_extra_headers` .. _GridFS: https://www.mongodb.com/docs/manual/core/gridfs/ fsc\V\4'g\RV,4hWn\ VPV4VnW0nW@nWPnR#)zDFirst argument to AIOHTTPGridFS must be AsyncIOMotorDatabase, not %rN) isinstancer TypeError _databaser_bucket_get_gridfs_file_get_cache_time_set_extra_headers)selfdatabaseroot_collectionr rrs&&&&&&r __init__AIOHTTPGridFS.__init__sS($899VYaa "/P /-"3r c ("VPR,pVPR 9d.\P P VPRR0R7hVPVPXV4GRjxL p\P P4p\T4pTPTPYST4TP!YS4TP"pTe\TP%TP&P(R7pTP&P%^R7p Y8dTP+R 4T#TP,P/R 4p T e*T P1R 4T8XdTP+R 4T#TP2TnTP7T4GRjxL TPR8Xdc^p YP28dQTP9TP:4GRjxL p TP=T 4GRjxL T \?T 4, p K`T# \d\T4EL&i;iEL \Pd1p\P PTPR7ThRp?ii;iLLL5i) z&Send filepath to client using request.rGETHEAD)methodallowed_methodsNrtzinfo) microsecondi0z If-None-Match")r6r7) rrr$r8r r!HTTPMethodNotAllowedr-r,gridfsNoFile HTTPNotFoundpathStreamResponser_set_standard_headersr/if_modified_sincereplace upload_dater; set_statusheadersgetstriplengthcontent_lengthprepareread chunk_sizewritelen) r0r rrerespchecksum ims_valueif_sinceretagwrittenchunks && r __call__AIOHTTPGridFS.__call__s/ #))*5H >> 0++22~~v3  E 11$,,'RRG{{))+!) ""7<<I .--  !((0C0C0J0J(KH**22q2AH#$ ""?3   38 ; OOC K%nnll7### >>U "GNN*%ll7+=+=>>jj'''3u:% g # ' " #S}} E++** *=1 D E@ $ ?'sJH$>J I6I7I;D/J*J +AJ0J1J J J$H>:J=H>>JIJ +JJ  JJJcxVPVnVPpVf\P!V4wrVV'dWRnRV,VP R&VP WPVP4pV^8d\PP\PP4PRR7\P!VR7,PR4VP R&R\V4,VP R&R#R VP R&R#) Nz"%s"Etagr:)secondsz%a, %d %b %Y %H:%M:%S GMTExpireszmax-age=z Cache-Controlpublic)rG last_modified content_type mimetypes guess_typerIr.datetimenowtimezoneutcrF timedeltastrftimestr)r0rBrTrrUrcencoding cache_times&&&&& r rD#AIOHTTPGridFS._set_standard_headerss$00++  %.%9%9$%? "L  , %0 V))$0C0CWEYEYZ >!!%%h&7&7&;&;<DDDDQ$$Z89h23 LL # -7Z,HDLL ),4DLL )r )r,r+r.r-r/N) __name__ __module__ __qualname____firstlineno____doc__r rrr3r[rD__static_attributes____classdictcell__) __classdict__s@r r&r&|s. J'%+ 4&7r55r r&)rtrfrd aiohttp.webr r?motor.motor_asynciorrmotor.motor_gridfsrr rrr$r&rr r r{s@ N, 9B 6&BE5E5r