update the database every 30 seconds
This commit is contained in:
parent
ffc5680445
commit
3d733feab1
1 changed files with 3 additions and 3 deletions
|
@ -44,8 +44,8 @@ rec_path = "/recordings"
|
||||||
# Bot functions
|
# Bot functions
|
||||||
@bot.event
|
@bot.event
|
||||||
async def on_ready():
|
async def on_ready():
|
||||||
# Schedule a database update to run every 5 seconds
|
# Schedule a database update
|
||||||
scheduler.add_job(func=query_database, trigger='interval', seconds=5, id='query_database')
|
scheduler.add_job(func=query_database, trigger='interval', seconds=30, id='query_database')
|
||||||
scheduler.start()
|
scheduler.start()
|
||||||
|
|
||||||
@bot.command(name='hello', help='Say hello to the bot')
|
@bot.command(name='hello', help='Say hello to the bot')
|
||||||
|
@ -142,7 +142,7 @@ async def query_database():
|
||||||
async with httpx.AsyncClient() as client:
|
async with httpx.AsyncClient() as client:
|
||||||
response = await client.get(db_url)
|
response = await client.get(db_url)
|
||||||
database = response.json()
|
database = response.json()
|
||||||
logger_discord.info(f'Database items {database.keys()}')
|
logger_discord.info(f'Database {database.keys()}')
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger_discord.error('Cannot connect to the database!')
|
logger_discord.error('Cannot connect to the database!')
|
||||||
logger_discord.error(e)
|
logger_discord.error(e)
|
||||||
|
|
Loading…
Add table
Reference in a new issue