I can't enter the except block, when i ecnonter 429, meraki aio returns it as a warning, so it's not being raised ... View more

There is one thing i don't understand. How do you use try/except to detect a 429 ? Because the AsyncRestSession code for 429 is this:                  elif status == 429:                     wait = 0                     if "Retry-After" in response.headers:                         wait = int(response.headers["Retry-After"])                     else:                         wait = random.randint(1, self._nginx_429_retry_wait_time)                     if self._logger:                         self._logger.warning(                             f"{tag}, {operation} > {abs_url} - {status} {reason}, retrying in {wait} seconds"                         )                     await asyncio.sleep(wait) So it is not raising any exception, therefore you can't catch it in your functions. ... View more

Thank you @sungod. Can you show me an example of o the wait/retry mechanism ? ... View more

Looking at logs, I see more than 5 calls pers second, I can't see where the issue is hiding ... View more

I had absolutely no idea about ._session._concurrent_requests_semaphore. So this by default submits 10 calls? Where you found it? Thanks ... View more

I don't see any kind of semaphore in your script. Using asyncio.as_completed should start all of them at once, so if your organization has 30 networks you start 30 workers and hit the rate limit. Am I wrong with this logic? ... View more

Thanks for the input, that's how i'm already checking the numer of calls by status code. All are provided by my script thst generates an output of aprox. 500 calls(200+429) for an organization with 120 networks, so the number of calls should be 120. My guess it's that meraki's library parameter wait_on_rate_limit and maximum_retries are causing many duplicates that are unnecessary. May the problem be that i initialize the meraki.aio for every call and it is unaware that it has other instances that are already doing the same thing ... View more

    async def getNetworkAppliancevlansMeraki(self,id😞         async with self.semaphore:             try:                 async with meraki.aio.AsyncDashboardAPI(self.api_key,self.base_url,output_log=False,print_console=True,suppress_logging=True,wait_on_rate_limit=True,maximum_retries=10) as aiomeraki:                     vlans = await aiomeraki.appliance.getNetworkApplianceVlans(id)                     return vlans             except meraki.AsyncAPIError as e:                 if e.status == 429:                     retry_after = int(e.response_headers.get('Retry-After', 1))                     log.info(f"Rate limit exceeded. Retrying after {retry_after} seconds.")                     await asyncio.sleep(retry_after)                 else:                     vlans= []                     log.info(f"Couldn't get Vlans , error: {e}")                     return vlans Even if i see hundreds of 429 calls, nothing raises my exception ... View more

I am using the meraki library, with an semaphore of 10 conccurent workers on top. Even so, when i check the number of calls, the 429 are hundreds. I don't know how to stop it. Once it start getting them, it seems it's never stopping ... View more

You are right, adapting from javascript to python is pretty easy. I think it would be beneficial to use the library for api calls instead of regular http calls in javascript where we would lack all the parameters the library offers ... View more

Everything seems fine, action batches gave me a hard time and I stopped trying to use them. Instead I work with meraki.aio library and make concurrent calls for efficiency ... View more

It's not about an easier solution. It's about automating a manual task, where network engineers have to manually create switch profiles from the dashboard. Or do you have another way to solve my problem ? ... View more

hopefully next api versions will implement it ... View more

Thank you sungod for your multiple answers to the topic. Unfortunately i have the same problem even with a simple python script. For me it makes sense. Concurrent calls go above 10 request per second, which is the limit from Meraki. I can't identify any mistake in my script that would do that ... View more

This is the problem. I want to postpone the automatic updates that meraki schedules. But I can't do that without affecting the updates scheduled by administrators. Thanks ... View more

and the loading of the page is infinite. So it is stuck somewhere the api request ... View more

The behavior is the same. what i observed is that i no longer get the error " 429 too many request" , but , there still are to many requests because if i make a random call on that specific organization in postman i get that there are to many api calls. So idk what to do anymore honestly ... View more

This might be an issue for my script, xd. Thanks   ... View more

  This is the script if it helps you more   async def get_organizations(): async with meraki.aio.AsyncDashboardAPI( api_key, base_url="https://api.meraki.com/api/v1", output_log = False, print_console = False, suppress_logging=True, wait_on_rate_limit=True, ##### do wait if rate limited maximum_retries=100 ##### set the retry limit ) as aiomeraki: organizations= await aiomeraki.organizations.getOrganizations() return organizations #################################################################################### FUNCTIONS #################################### async def get_template_name(org_id,config_template_id): async with meraki.aio.AsyncDashboardAPI( api_key, base_url="https://api.meraki.com/api/v1", output_log = False, print_console = False, suppress_logging=True, wait_on_rate_limit=True, ##### do wait if rate limited maximum_retries=100 ##### set the retry limit ) as aiomeraki: template=await aiomeraki.organizations.getOrganizationConfigTemplate( org_id, config_template_id ) template_name=template['name'] return template_name async def append_template(network,org_id): template_list=[] if network['isBoundToConfigTemplate']==True: template_name= await get_template_name(org_id,network['configTemplateId']) template= {"id" :network['configTemplateId'], "name" :"Template - "+ template_name } if template not in template_list: template_list.append(template) elif network['isBoundToConfigTemplate']==False: network={"id":network['id'],"name":"Network - " +network['name']} if network not in template_list: template_list.append(network) await asyncio.sleep(2) return template_list #################################################################################### ROUTES ####################################### @app.route('/favicon.ico') async def favicon(): return "Da" @app.route("/") async def render_organizations(): organizations=await get_organizations() return render_template("organizations.html",organizations=organizations) @app.route('/<org_id>') async def organization_detail(org_id): organization_id = org_id async with meraki.aio.AsyncDashboardAPI( api_key, base_url="https://api.meraki.com/api/v1", output_log=False, print_console=False, suppress_logging=True, wait_on_rate_limit=True, ##### do wait if rate limited maximum_retries=100 ##### set the retry limit ) as aiomeraki: try: networks = await aiomeraki.organizations.getOrganizationNetworks( organization_id, total_pages="all" ) except OSError as e: print(e) template_list = [] # create a list of all network template tasks network_template_tasks = [append_template(net, org_id) for net in networks] # iterate over the completed tasks as they finish for coro in asyncio.as_completed(network_template_tasks): # await asyncio.sleep(2) template_list.extend(await coro) return render_template("templates.html", templates=template_list)   ... View more

.getOrganizationConfigTemplate does not support neither totalPages not per_page ... View more