def ajax_endpoint(environ, start_response):
# WSGI????????????????????????????HTTP???
# ??????WSGI?????HTTP?????????????environ——??????
# HTTP?????dict???start_response——????HTTP??????
status = '200 OK'
headers = [
('Content-Type', 'application/json')
]
start_response(status, headers)
while True:
try:
datum = data_source.get(timeout=5)
yield json.dumps(datum) + '\n'
except Empty: pass
评论列表
文章目录