[FIXED] asyncio.sleep() - how to use it?

Issue

Can anyone help me out, I'm trying to get the program to pause if the condition is met. But as of now, its not sleeping at all. And I can't wrap my head around why. Im completely new to asyncio

time.sleep() doesnt really work either, so I would prefer to use asyncio. Thanks alot!

from python_graphql_client import GraphqlClient
import asyncio
import os
import requests

loop = asyncio.get_event_loop()

def print_handle(data):
    print(data["data"]["liveMeasurement"]["timestamp"]+" "+str(data["data"]["liveMeasurement"]["power"]))
    tall = (data["data"]["liveMeasurement"]["power"])
    if tall >= 1000:
        print("OK")
        # schedule async task from sync code
        asyncio.create_task(send_push_notification(data))
        print("msg sent")
        asyncio.create_task(sleep())
        
        

client = GraphqlClient(endpoint="wss://api.tibber.com/v1-beta/gql/subscriptions")

query = """
subscription{
  liveMeasurement(homeId:"fd73a8a6ca"){
    timestamp
    power
    
  }
}
"""

query2 = """
mutation{
  sendPushNotification(input: {
    title: "Advarsel! Høyt forbruk",
    message: "Du bruker 8kw eller mer",
    screenToOpen: CONSUMPTION
  }){
    successful
    pushedToNumberOfDevices
  }
}
"""
async def sleep():
    await asyncio.sleep(10)

async def send_push_notification(data):
    #maybe update your query with the received data here
    await client.execute_async(query=query2,headers={'Authorization': "2bTCaFx74"}) 
    

async def main():
    await client.subscribe(query=query, headers={'Authorization': "2bTCaFxDiYdHlxBSt074"}, handle=print_handle)
    
asyncio.run(main())

Solution

I think the easiest way to reduce the number of messages being sent, is to define a minimum interval in which no notification is sent while the value is still over the threshold.

import time


last_notification_timestamp = 0
NOTIFICATION_INTERVAL = 5 * 60  # 5 min

def print_handle(data):
    global last_notification_timestamp
    print(
        data["data"]["liveMeasurement"]["timestamp"]
        + " "
        + str(data["data"]["liveMeasurement"]["power"])
    )
    tall = data["data"]["liveMeasurement"]["power"]
    current_time = time.time()
    if (
        tall >= 1000
        and current_time - NOTIFICATION_INTERVAL > last_notification_timestamp
    ):
        print("OK")
        # schedule async task from sync code
        asyncio.create_task(send_push_notification(data))
        last_notification_timestamp = current_time
        print("msg sent")

The timestamp of the last message sent needs to be stored somewhere, so we'll define a variable in the global scope to hold it and use the global keyword within print_handle() to be able to write to it from within the function. In the function we will then check, if the value is above the threshold and enough time passed after the last message. This way you will still keep your subscription alive as well as limit the number of notifications you receive. This is simple enough but probably you will soon want to extend the range of what you want to do with your received data. Just keep in mind that print_handle() is a sync callback and should be as short as possible.

Answered By - thisisalsomypassword