9h$pSrSSKrSSKrSSKrSSKrSSKJrJr SSK J r Sr Sr Sr Sr"S S 5rg) 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$URU5$)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 [C:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\motor/aiohttp/__init__.pyget_gridfs_filer "s<  . .x 88cg)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" r)r modified mime_types r get_cache_timerCs0 r cg)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 cURRRR5SnSU-n[ RRUS9Se![[ 4a SU-nN5f=f)N formatterz>@M LyX ++ - -3 - 7TA n %B7'ABs6AA.-A.c6\rSrSrSrS\\\4SjrSr Sr Sr g) AIOHTTPGridFS|aServe 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[U[5(d[SU-5eXl[ URU5UlX0lX@lXPlg)NzDFirst argument to AIOHTTPGridFS must be AsyncIOMotorDatabase, not %r) 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 # URSnURS;a*[R R URSS1S9eURURWU5IShvN n[R R5n[U5nURURXSU5 UR!XS5 UR"nUbTUR%UR&R(S9nUR&R%S S 9n X:aUR+S 5 U$UR,R/S 5n U b(U R1S 5U:XaUR+S 5 U$UR2UlUR7U5IShvN URS:XalS n XR2:a[UR9UR:5IShvN n UR=U 5IShvN U [?U 5- n XR2:aM[U$![a [U5 GN f=fGN![Ra-n[R RURS9UeSnAff=fNNN7f)z&Send filepath to client using request.r )GETHEADr8r9)methodallowed_methodsNrtzinfor) microsecondi0z If-None-Match") rrr%r:r!r"HTTPMethodNotAllowedr/r.gridfsNoFile HTTPNotFoundpathStreamResponser_set_standard_headersr1if_modified_sincereplace upload_dater= set_statusheadersgetstriplengthcontent_lengthprepareread chunk_sizewritelen) r2r r rerespchecksum 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:% NN*  g # ' " #S}} E++** *=1 D E@ $ ?'sJH:J H:.H7/H:3D%JI>AJJJ5J6!JJH40J3H44J7H::I;(I66I;;JJJcJURUlURnUc[R"U5upVU(aXRlSU-UR S'UR XRUR5nUS:a[RR[RR5RSS9[R"US9-RS5UR S'S[U5-UR S 'gS UR S 'g) Nz"%s"Etagrr<)secondsz%a, %d %b %Y %H:%M:%S GMTExpireszmax-age=z Cache-Controlpublic)rI last_modified content_type mimetypes guess_typerKr0datetimenowtimezoneutcrH timedeltastrftimestr)r2rDrVrrWreencoding cache_times r rF#AIOHTTPGridFS._set_standard_headerss$00++  %.%9%9$%? "L  , %0 V))$0C0CWEYEYZ >!!%%h&7&7&;&;<DDDDQ$$Z89h23 LL # -7Z,HDLL ),4DLL )r )r.r-r0r/r1N) __name__ __module__ __qualname____firstlineno____doc__r rrr5r]rF__static_attributes__rr r r'r'|s& J'%+ 4&7r5r r')rvrhrf aiohttp.webr!rAmotor.motor_asynciorrmotor.motor_gridfsrr rrr%r'rr r r{s@ N, 9B 6&BE5E5r