1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
import os
async def handler(prefix, scope, receive, send):
if scope['type'] == 'lifespan':
with open(f'{prefix}version', 'w+') as f:
f.write(
f"{scope['asgi']['version']} {scope['asgi']['spec_version']}"
)
while True:
message = await receive()
if message['type'] == 'lifespan.startup':
os.remove(f'{prefix}startup')
await send({'type': 'lifespan.startup.complete'})
elif message['type'] == 'lifespan.shutdown':
os.remove(f'{prefix}shutdown')
await send({'type': 'lifespan.shutdown.complete'})
return
if scope['type'] == 'http':
await send(
{
'type': 'http.response.start',
'status': 204,
'headers': [
(b'content-length', b'0'),
],
}
)
async def application(scope, receive, send):
return await handler('', scope, receive, send)
async def application2(scope, receive, send):
return await handler('app2_', scope, receive, send)
|
