我试图通过使用aiohttp从url获取查询字符串参数，但是此代码不起作用：
async def call_answer(request):
print("request", request)
params = request.rel_url.query
print("parameters +++++", params["call_id"])
conn = psycopg2.connect(connect_str)
cursor = conn.cursor()
sql = """
update calls
set status = %s
where id = %s;
""" % (params["status"], params["call_id"])
cursor.execute(sql)
conn.commit()
return web.Response(
content_type='application/json',
text=json.dumps({
'status': 'success'
}))
if __name__ == '__main__':
parser = argparse.ArgumentParser(description='WebRTC audio / video / data-channels demo')
parser.add_argument('--port', type=int, default=8080,
help='Port for HTTP server (default: 8080)')
parser.add_argument('--verbose', '-v', action='count')
args = parser.parse_args()
if args.verbose:
logging.basicConfig(level=logging.DEBUG)
app = web.Application()
app.router.add_get('/{call_id}&{status}', call_answer)
我在互联网上搜索，到处都写着应该使用request.rel_url.query从查询字符串中获取所有参数的信息，但是在运行代码时出现错误！
您不得在路由指定中添加查询字符串，因为aiohttp在进行路由匹配时会丢弃查询字符串。request.rel_url.query效果很好，这是一个示例：
from aiohttp import web
async def call_answer(request):
params = request.rel_url.query
return web.Response(text='\n'.join([
'call_id = ' + params['call_id'],
'status = ' + params['status'],
]))
app = web.Application()
app.router.add_get('/', call_answer)
web.run_app(app)
测试它：
$ curl 'localhost:8080/?call_id=100&status=200'
call_id = 100
status = 200
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句