I made a code but it gives error unable to close a running loop Code is import aiohttp import asyncio async def get_response(query): async with aiohttp.ClientSession() as ses: async with ses.get( f’https://some-random-api.ml/chatbot?message={query}’ ) as resp: return (await resp.json()),[‘response’] #using an event loop loop = asyncio.get_event_loop() Task = asyncio.gather(*[get_response(‘world’) for _ in range(500)]) try: loop.run_until_complete(Task) finally: ..
Category : aiohttp
I’m building a bot in discord.py to search an API for a baseball player’s name and only send the matching result(s) via discord. I’ve got everything working properly, except it only works if the player’s name is on the first page of the API response. There are 122 total pages of results. I’m using the ..
My unedited code is import aiohttp import asyncio async def get_response(query): async with aiohttp.ClientSession() as ses: async with ses.get( f’https://some-random-api.ml/chatbot?message={query}’ ) as resp: return (await resp.json())[‘response’] #using an event loop loop = asyncio.get_event_loop() Task = asyncio.gather(*[get_response(‘world’) for _ in range(500)]) try: loop.run_until_complete(Task) finally: loop.close() It returns response like ({‘response’: "What’s up?"}, [‘response’]) How to modify ..
server.py import asyncio import json import os from aiohttp import web from aiortc import RTCPeerConnection, RTCSessionDescription ROOT = os.path.dirname(__file__) pcs = set() async def index(request): content = open(os.path.join(ROOT, "index.html"), "r").read() return web.Response(content_type="text/html", text=content) async def javascript(request): content = open(os.path.join(ROOT, "client.js"), "r").read() return web.Response(content_type="application/javascript", text=content) async def offer(request): params = await request.json() offer = RTCSessionDescription(sdp=params["sdp"], type=params["type"]) ..
I have written such WebSocket client: <!DOCTYPE html> <html> <head> <title></title> <script type="text/javascript"> connection = new WebSocket("ws://myapp.herokuapp.com/:8080"); connection.onopen = function() { console.log("Connected!"); //collect data let msg = { type: "test_type", date: "test_data" } let json = JSON.stringify(msg); connection.send(json); }; function testSend() { let msg = { type: "test_type", date: "test_data" } let json = JSON.stringify(msg); ..
A friend of mine has made this code THE CODE IS Credits: TERMINATOR import aiohttp import asyncio async def get_response(query): async with aiohttp.ClientSession() as ses: async with ses.get( f’https://some-random-api.ml/chatbot?message={query}’ ) as resp: return (await resp.json()),[‘response’] #using an event loop loop = asyncio.get_event_loop() Task = asyncio.gather(*[get_response(‘world’) for _ in range(500)]) try: loop.run_until_complete(Task) finally: loop.close() BUT IT ..
A friend of mine has made this code THE CODE IS Credits: TERMINATOR import aiohttp import asyncio async def get_response(query): async with aiohttp.ClientSession() as ses: async with ses.get( f’https://some-random-api.ml/chatbot?message={query}’ ) as resp: return (await resp.json())[‘response’] #using an event loop loop = asyncio.get_event_loop() Task = asyncio.gather(*[get_response(‘world’) for _ in range(500)]) try: loop.run_until_complete(Task) finally: loop.close() AND ALSO ..
I’m building a command onto an existing bot that will search an API and take a baseball player’s name as a parameter to query a json response with. I’ve gotten everything to work correctly in test, only for the life of me I can’t figure out how to restrict the results to only those that ..
my unedited code import asyncio async def get_response(query): async with aiohttp.ClientSession() as ses: async with ses.get( f’https://some-random-api.ml/chatbot?message={query}’ ) as resp: return (await resp.json())[‘response’] def main(): print(asyncio.run( get_response(‘world’)))# use asyncio.run to call an async funtion If you can please also try to add cooldown between the requests Source: Python-3x..
This bot is made for chatting like a human where it uses a endpoint it works good but sometimes uhh I tried my best to solve it but it still gives error… Please check my code and report any modifications to it My unmodified code import aiohttp import asyncio async def get_response(query): async with aiohttp.ClientSession() ..
Recent Comments