faust.web.drivers.aiohttp

Web driver using aiohttp.

class faust.web.drivers.aiohttp.Web(app: faust.types.app.AppT, **kwargs) → None[source]

Web server and framework implemention using aiohttp.

driver_version = 'aiohttp=3.5.4'
handler_shutdown_timeout = 60.0
cors
Return type:CorsConfig
text(value: str, *, content_type: str = None, status: int = 200, reason: str = None, headers: MutableMapping = None) → faust.web.base.Response[source]
Return type:Response
html(value: str, *, content_type: str = None, status: int = 200, reason: str = None, headers: MutableMapping = None) → faust.web.base.Response[source]
Return type:Response
json(value: Any, *, content_type: str = None, status: int = 200, reason: str = None, headers: MutableMapping = None) → Any[source]
Return type:Any
bytes(value: bytes, *, content_type: str = None, status: int = 200, reason: str = None, headers: MutableMapping = None) → faust.web.base.Response[source]
Return type:Response
route(pattern: str, handler: Callable, cors_options: Mapping[str, aiohttp_cors.resource_options.ResourceOptions] = None) → None[source]
Return type:None
add_static(prefix: str, path: Union[pathlib.Path, str], **kwargs) → None[source]
Return type:None
bytes_to_response(s: bytes) → faust.web.base.Response[source]
Return type:Response
response_to_bytes(response: faust.web.base.Response) → bytes[source]
Return type:bytes
logger = <Logger faust.web.drivers.aiohttp (WARNING)>
coroutine on_start(self) → None[source]

Service is starting.

Return type:None
coroutine read_request_content(self, request: faust.web.base.Request) → bytes[source]
Return type:bytes
coroutine start_server(self) → None[source]
Return type:None
coroutine stop_server(self) → None[source]
Return type:None
coroutine wsgi(self) → Any[source]
Return type:Any