motion event often not triggered, pullmessages.CurrentTime one hour late with real camera current time

[pakheper]

onvif-python==0.2.10
zeep==4.3.2
requests==2.32.5
urllib3==2.6.2
Python 3.11.2

device tapo C210
firmware : 1.2.5 (last available version for C210)

I control and handle onvif camera events via a python script using the onvif-python module on a raspberry pi5. let's name OnvifClient on this machine as NVR
In the python script i implement the onvif real-time notification interface as you describe in your deepwiki.

i proceed in two test methods : creating the pullpoint subcription with no inital TerminationTime to test the subscription Renew or in the second way with a one year duration ("PT8274H") in order to never fall in subscription dismiss for a while

issues

i encounter several technical malfuntions i can't determine the origin preventing a live environnement implementation.
First of all, C210 camera always locally detects motion (i receive a phone notification by the TPlink Tapo app, alarm is raised)

the main problem is that an event is often not triggered towards pullpoint of the NVR after the camera detects a motion.
the event is triggred after the first time i launch the NVR python script and not triggered some time later, the Onvif client beeing still alive and subcription as well.

case 1 : i mention no initial TerminationTime in the pullpoint CreatePullPointSubscription request

i noticed in the pullmessage response that the message.CurrentTime is one hour late compared to the camera currenttime value i get with the onvif.client query devicemgmt_service. GetSystemDateAndTime ()
which is the correct currenttime as the Europe/brussel timezone declared for the camera in the Tplink Tapo app and the same time of the NVR one.

the TerminationTime returned by the pullmessage response is 10 minutes relative from the first message.CurrentTime returned.
this TerminationTime is not reevaluated till the pullmessage fails in expirated TerminationTime (the keep-alive mecanism is not supported)

I tried to do a subscription Renew taking in account the remainning difference between the message.TerminationTime and the message.CurrentTime
but the Renew statement (subscription.Renew (TerminationTime="PT10M")) fails with ONVIF operation 'Renew' failed: SOAP Error: code=SOAP-ENV:Sender, subcode=InvalidArgVal, msg=error

in case of motion triggered event detected by the pullmessages , the time of the detected IsMotion is also timestamped one hour later it really happened.
The pullmessage receives about one hundred messages with operationtype 'initialized' and 'IsMotion' data set to True. the last message has 'IsMotion' data set to False.
i launch a rtsp stream recording when IsMotion data becomes False in the last messages.

I asked the TPlink support what is the reason for such a big messages number for one motion detection. they reply that this beheavior looks like a Basic notification interface rather than a real-time notification interface. what do you think of?

case 2 : setting a one year absolute TerminateTime while creating pullpoint.

The camera doesn't refuse this duration, the pullmessages response returns a CurrentTime late of one hour as above case1.
the pullmessages returned a constant TerminationTime equal with the one i set. the camera stays inside subcription time.
I notice the same no triggered motion event during an elapsed time and the big number of IsMotion data at true value in case of event trigerred.

I need some candle light

[kaburagisec]

Okay, thank you for the report. Are you using a sample script? If not, could you provide a snippet of the script you're using so I can analyze it?

[pakheper]

Hi, I join here the dev script i use to manage several tapo C210 cameras. Below are the main features of this script to help you analyzing I use only a one year initial TerminationTime for subscriptions (no automatic Renew in this version) i use several tables indexed by cam_idx to store services instanciation objects attached to each camera (subcription, pullpoint, events, etc) The script uses two files containing parameters - one file contains the cameras list with for each camera : site,name,adresse ip, its Tplink Tapo app account (user and pwd) - one file contains general parameters : TerminationTime to use, number of snapshots to take before rtsp video recording, video_format to use, etc Once a motion is detected the script emits a personnal push notification with app Pushover to my phone (in addition with one from the tapo center) and takes snaphots and video recording. I send them to my own cloud (pcloud) ; I don't use camera local storage SD card nor the official Tplink tapo-care cloud. For video recording i use the direct rtsp protocol rather than the onvif media service The main starting part of the programm reads the parameters files and create an onvif-client for each camera. i use port 2020 for the onvif-clients creation , the others ports (80, 8080, 443) are refused by the cameras. Once all the onvif-clients are created i launch a thread (tapo-listen) for each camera where i proceed to the camera pullmessages loop. i launch another thread (tapo_commande) to execute onvif commande i submit from the console. The motion detection setting is always locally activated in each tapo camera , i can also activate person detection setting. For messages parsing i don't use the onvifclient plugin argument. I transform the received messages in dict form with the module zeep.helpers.serialize_object(msg, dict) at this point here is the 'IsMotion' message format I receive :. Topic always have a None value i always take in account the following part of the message: Data': { 'SimpleItem': { 'Value': False, 'Name': 'IsMotion' as i told you in case of motion detection i receive one hundred 'Initialized' IsMotion messages with Value set to True that i discard as duplicate before the last with Value = False that i retain. whole message : { 'SubscriptionReference': { 'Address': { '_value_1': None, '_attr_1': None }, 'ReferenceParameters': None, 'Metadata': None, '_value_1': None, '_attr_1': None }, 'Topic': { '_value_1': None, 'Dialect': 'http://www.onvif.org/ver10/tev/topicExpression/ConcreteSet', '_attr_1': { } }, 'ProducerReference': None, 'Message': { '_value_1': [ <Element {http://www.onvif.org/ver10/schema}Message at 0x7ffefeab19c0> ], 'Message': { 'PropertyOperation': 'Initialized', 'UtcTime': '2025-11-25T18:16:14Z', 'Source': { 'SimpleItem': { 'Value': 'MyMotionDetectorRule', 'Name': 'Rule' } }, 'Data': { 'SimpleItem': { 'Value': False, 'Name': 'IsMotion' } } } } } i hope that helps, thanks for the time spent on this problem. best regards Envoyé avec un e-mail sécurisé [Proton Mail](https://proton.me/mail/home). Le mardi 24 mars 2026 à 14:31, Kaburagi ***@***.***> a écrit :

kaburagisec left a comment [(nirsimetri/onvif-python#28)](#28 (comment)) Okay, thank you for the report. Are you using a sample script? If not, could you provide a snippet of the script you're using so I can analyze it? — Reply to this email directly, [view it on GitHub](#28?email_source=notifications&email_token=BJ3LJDF67MCEJBMSDZ2P2PL4SKE2FA5CNFSNUABFM5UWIORPF5TWS5BNNB2WEL2JONZXKZKDN5WW2ZLOOQXTIMJRHAZTGNJVGE32M4TFMFZW63VGMF2XI2DPOKSWK5TFNZ2KYZTPN52GK4S7MNWGSY3L#issuecomment-4118335517), or [unsubscribe](https://github.com/notifications/unsubscribe-auth/BJ3LJDC4PXCHGQ6CFGSLLRT4SKE2FAVCNFSM6AAAAACW4H7BCKVHI2DSMVQWIX3LMV43OSLTON2WKQ3PNVWWK3TUHM2DCMJYGMZTKNJRG4). You are receiving this because you authored the thread.Message ID: ***@***.***>

# -*- coding: utf-8 -*- """ Created on Sat Nov 22 17:48:37 2025 Tables indexée par caméra : tapo_cam_list : table de toutes les caméras déclarées dans le fichier '.ini' tapo_onvif_connected_list : tables des caméras qui ont réussi leur init (céation d'un onvif client et souscription à Pullmessages) tapo_onvifclient_list : contient l'instance ONVIFClient associée à chaque caméra tapo_devicemgmt_service_list : contient l'instance du service 'devicemgmt' associé à la caméra tapo_events_service_list : contient l'instance du service 'events' associé à la caméra tapo_ptz_service_list : contient l'instance du service 'ptz' associé à la caméra tapo_media_service_list : contient l'instance du service 'media' associé à la caméra (non utilisé pour l'enregistremet video, use of rtsp direct) tapo_imaging_service_list : contient l'instance du service 'imaging' associé à la caméra tapo_analytics_service_list : contient l'instance du service 'imaging' associé à la caméra tapo_pullpoint_service_list : contient l'instance du service 'pullpoint' associé à la caméra tapo_notification_service_list : contient l'instance du service 'notification' associé à la caméra tapo_subscription_service_list : contient l'instance du service 'subscription' associé à la caméra tapo_subscription_termination_time : contient le temps calculé de la date et heure de la fin de la souscrion pour la camér tapo_recording_in_progress_list : indique si un enregistrement video (recording) est en cours pour la caméra lecture camera tapo C210 1. séparation des consoles (terminal) pour séparer les messages qui proviennent des caméras de ceux qui sont consécutifs aux commandes onvif passées aux caméras il faut installer la commande gnome-terminal sur le rpi (sudo apt-get -y install gnome-terminal) ensuite il faut installer le module pypi python 'window-terminal' (pip install window-terminal) @author: PA1 """ import os import sys from onvif import ONVIFClient, CacheMode import zeep import time import datetime import platform import threading import subprocess import cv2 import syslog from window_terminal import WindowTerminal # ouverture d'un nouveau terminal pour recevoir les messages issus des commandes passées vers les camréras from xo_lib import chdc_file, coloring li_cr = '\n' adm_traced = False adm_message_traced = False pcloud_storage_enabled = True windows_run = False linux_run = False android_run = False info = 'info' err = 'err' info_c = 'info_c' err_c = 'err_c' ''' valeurs par défaut des paramètres (toutes les valeurs sont normallement chargées à partir du fichier tapo.ini) ''' p_env = 'ENV_tapo' #environnement virtuel bookworm p_video_recording_duration = 120 p_format_video_mp4 = '.mp4' p_format_video_avi = '.avi' p_format_video = p_format_video_mp4 p_nb_snapshots = 3 p_subscription_duration_unit = 'M' p_subscription_duration = 5 subscribe_initial_time = 'PT' + str (p_subscription_duration) + p_subscription_duration_unit p_ONVIFClient_capture_xml = False p_cv2_imshow_motion_recording = False p_reboot_enabled = True port_onvif = 2020 port_rtsp = 554 protocol_rtsp = 'rtsp://' user = '' passwd = '' ''' tables contenant les infos de chaque caméra ''' tapo_cam_list = [] # tables de toutes les caméras déclarées dans le fichier '.ini' tapo_onvif_connected_list = [] # tables des caméras qui ont réussi leur init (céation d'un onvif client et souscription à Pullmessages) tapo_onvifclient_list = [] tapo_devicemgmt_service_list = [] tapo_events_service_list = [] tapo_ptz_service_list = [] tapo_media_service_list = [] tapo_imaging_service_list = [] tapo_analytics_service_list = [] tapo_pullpoint_service_list = [] tapo_notification_service_list = [] tapo_subscription_service_list = [] tapo_subscription_termination_time = [] tapo_recording_in_progress_list = [] GetHostnamev = 'GetHostname' GetDNSv = 'GetDNS' GetNTPv = 'GetNTP' GetNetworkInterfacesv = 'GetNetworkInterfaces' GetNetworkProtocolsv = 'GetNetworkProtocols' GetNetworkDefaultGatewayv = 'GetNetworkDefaultGateway' GetZeroConfigurationv = 'GetZeroConfiguration' GetIPAddressFilterv = 'GetIPAddressFilter' GetEventPropertiesv = 'GetEventProperties' cmd_infosv = '1. infos' cmd_currenttimev = '2. currenttime' cmd_subscription_TerminationTimev = '3. subscription TerminationTime' cmd_unsubscribev = '4. unsubscribe' cmd_recording_statev = '5. recording state' cmd_reset_recording_statev = '6. reset_recording state' cmd_set_adm_message_tracedv = '7. set adm_message_traced' cmd_reset_adm_message_tracedv = '8. reset adm_message_traced' cmd_rebootv = '9. reboot' tapo_commandes_list = [ cmd_infosv , cmd_currenttimev , cmd_subscription_TerminationTimev , cmd_unsubscribev , cmd_recording_statev , cmd_reset_recording_statev , cmd_set_adm_message_tracedv , cmd_reset_adm_message_tracedv , cmd_rebootv ] valide_commande = [1,2,3,4,5,6,7,8,9] ''' ----------------- Main ------------------- ''' plate_forme = platform.system() if plate_forme == 'Windows': windows_run = True path_file_ini = 'C:/_00PY/_WinPython/common/tapo/tapo.ini' if plate_forme == 'Linux': if not os.path.exists ('/storage/emulated') : linux_run = True path_file_ini = '/home/xxx/' + p_env + '/progs/tapo/tapo.ini' script_pcloud_upload_file = '/home/xxx/' + p_env + '/progs/script_motion_Tapo_start_pcloud_upload_file.sh' else : android_run = True path_file_ini = '/storage/emulated/0/tapo/tapo.ini' # ----------------------------------------------------------------------------- def lprint (*args) : if len (args) == 1 : term_cmd.print (args [0]) if len (args) == 2 : term_cmd.print (args [0] , args [1]) def on_syslog (log_category, log_text, printable ) : color_infotext_list = ['starting', 'recording', 'IsMotion'] def colored (text) : for item in color_infotext_list : if item in text : return True return False log_id = '>>>' if log_category == info or log_category == info_c : category = ' [Info] ' if log_category == err or log_category == err_c : category = ' [ERR ] ' text = log_id + category + str (log_text) if log_category == info or log_category == info_c : syslog.syslog(syslog.LOG_INFO, text) if log_category == err or log_category == err_c : syslog.syslog(syslog.LOG_ERR, text) if printable : if log_category == info : if colored (text) : text = log_id + ' ' + str (log_text) print (p.color_term_info (text)) else : print (text) if log_category == err : text = log_id + ' ' + str (log_text) print (p.color_term_err (text)) if log_category == info_c or log_category == err_c : lprint (text) # ----------------------------------------------------------------------------- file_device_ini = open (path_file_ini, 'r', encoding = 'utf-8') f_tapov = 'tapo' f_environv = 'environ' f_video_recording_durationv = 'video_recording_duration' f_format_videov = 'format_video' f_snapshotsv = 'snapshots' f_subscription_duration_unitv = 'subscription_duration_unit' f_subscription_durationv = 'subscription_duration' f_ONVIFClient_capture_xmlv = 'ONVIFClient_capture_xml' f_cv2_imshow_motion_recording = 'cv2_imshow_motion_recording' # pour tests f_reboot_enabled = 'reboot_camera_enabled' while True : line = file_device_ini.readline () if adm_traced : print ('>>> line' , line) if len (line) == 0 or len (line [0:1]) == '*' : break if line [0:1] != '#' : line = line.replace ('\n', '') line = line.replace ('\r', '') line = line.replace ('\t', '') key = line.split('=') [0] . strip (' ') value = line.split('=') [1] . strip (' ') if key == f_tapov : tapo_tup = value.split ('/') tapo_site = tapo_tup [0] tapo_name = tapo_tup [1] tapo_ip = tapo_tup [2] tapo_room = tapo_tup [3] tapo_cam_list.append (value) if key == f_environv : p_env = value if key == f_video_recording_durationv : p_video_recording_duration = int (value) if key == f_format_videov : p_format_video = value if key == f_snapshotsv : p_nb_snapshots = int (value) if key == f_subscription_duration_unitv : p_subscription_duration_unit = value if key == f_subscription_durationv : p_subscription_duration = int (value) if key == f_ONVIFClient_capture_xmlv : p_ONVIFClient_capture_xml = True if value == 'True' else False if key == f_cv2_imshow_motion_recording : p_cv2_imshow_motion_recording = True if value == 'True' else False if key == f_reboot_enabled : p_reboot_enabled = True if value == 'True' else False file_device_ini.close () for item in tapo_cam_list : on_syslog (info, item, adm_traced) def get_pass () : global user global passwd user = '' passwd = '' import tempfile if windows_run : path_file_cred_tapo = 'C:/_00PY/_WinPython/common/tapo/tapo.chf' if android_run : path_file_cred_tapo = '/storage/emulated/0/_00PY/tapo/tapo.chf' if linux_run : path_file_cred_tapo = '/home/xxx/' + p_env + '/progs/tapo/tapo.chf' try : file_out = tempfile.TemporaryFile(mode='w+b') file_in = open (path_file_cred_tapo, 'rb') chdc_file ('dcf', file_in, file_out , 'xxxxxxxxx') file_out.seek (0) line = file_out.readline ().decode ('utf-8') line = line.replace (li_cr, '') line = line .strip () user = line.split ('/') [0] passwd = line.split ('/') [1] except : msg = "Erreur sur decodage login, mot de passe" on_syslog (err, msg, True) terminate() file_in.close () file_out.close () def on_horodatage () : now = time.localtime() now_annee = int (time.strftime("%Y" , now)) now_mois = int (time.strftime("%m" , now)) now_jour = int (time.strftime("%d" , now)) now_hh = int (time.strftime("%H" , now)) now_mm = int (time.strftime("%M" , now)) now_ss = int (time.strftime("%S" , now)) horodate = datetime.datetime (now_annee, now_mois, now_jour ,now_hh, now_mm, now_ss) return str(horodate) def on_horodatage_video () : horodate = on_horodatage (). replace (' ', 'T') # horodate de la forme 2025-12-02 18:03:01 horodate = horodate.replace (':','-') return horodate def terminate () : msg = 'terminating ...' on_syslog (err, msg, True) sys.exit (-1) def pushover_notification (site, text) : text_color = 'red' path_file_python3 = '/usr/bin/python3' path_file_prog_DWR921_notification_push = '/usr/local/bin/PROG-DWR921_notification_push.py' push_text = ***@***.***<>' + 'admin' + site + '<>' + text + '<>' + text_color + '<>' subprocess.call ([path_file_python3, path_file_prog_DWR921_notification_push, push_text] ) ''' ------ main ---------- ''' def cam_index (cam_name) : for i in range (len (tapo_onvif_connected_list)) : if tapo_onvif_connected_list [i] . split ('/') [1] == cam_name : cam_idx = i break return cam_idx # ----------------------------------------------------------------------------- class tapo_upload_pcloud (threading.Thread) : def __init__(self, files_list, files_type): # le Thread reçoit en paramètre la liste des fichiers et leur type ('img' ou 'video') threading.Thread.__init__(self) # ne pas oublier cette ligne self.files_list = files_list self.files_type = files_type def run (self) : if self.files_type == 'img' : # resize des fichiers img pcloud_files = '' for path_file in self.files_list : img_in = cv2.imread (path_file) img_out = cv2.resize (img_in, (1280,720)) cv2.imwrite (path_file, img_out) pcloud_files += path_file + ',' pcloud_files = pcloud_files.strip (',') if self.files_type == 'video' : pcloud_files = '' for path_file in self.files_list : pcloud_files += path_file + ',' pcloud_files = pcloud_files.strip (',') if pcloud_storage_enabled : try : subprocess.Popen (['/bin/bash', script_pcloud_upload_file, pcloud_files]) except Exception as e: mess = 'Exception pcloud transfert sur fichier ' + pcloud_files + li_cr + str(e) on_syslog (err, mess, True) # ----------------------------------------------------------------------------- class tapo_snapshot () : def __init__(self, cam_site, cam_name, cam_ip, cam_idx): self.cam_site = cam_site self.cam_name = cam_name self.cam_ip = cam_ip self.cam_idx = cam_idx def run (self) : mess = "starting thread 'tapo_snapshot' for cam " + self.cam_name + ' (' + self.cam_ip + ')' on_syslog (info, mess, True) def on_horodatage_snapshot () : horodate = on_horodatage (). replace (' ', '_h') # horodate de la forme 2025-12-02 18:03:01 horodate = horodate.replace (':','-') return horodate path_dir_images = '/home/xxx/TAPO/' + self.cam_name + '-tapo' + '/images/' url_rtsp = 'rtsp://' + user+ ':' + passwd url_rtsp += '@' + self.cam_ip + ':' + str (port_rtsp) + '/stream1' # flux HD} images_list = [] cam = cv2.VideoCapture (url_rtsp) if not cam.isOpened() : mess = "La caméra " + self.cam_name + " n'est pas à l'état open, recommencer" on_syslog (err, mess, True) return else : for i in range (p_nb_snapshots) : result, frame = cam.read() if not result : break z = 1 if i < 10 else 0 num_img = 'n' + ("0" * z) + str (i) img_name = path_dir_images + 'img_' + on_horodatage_snapshot() + '_' + num_img + '.jpg' #print ('>>> image', img_name) cv2.imwrite(img_name, frame) images_list.append (img_name) if cv2.waitKey(20) & 0xFF == ord('q'): break cam.release() cv2.destroyAllWindows() # libération du lock , le recording video peut suivre # envoi des images vers pcloud p_upload = tapo_upload_pcloud (images_list, 'img') p_upload.start () # ---------------------------------------------------------------------------- class tapo_record (threading.Thread) : def __init__(self, cam_site, cam_name, cam_ip, cam_idx): threading.Thread.__init__(self) # ne pas oublier cette ligne self.cam_site = cam_site self.cam_name = cam_name self.cam_ip = cam_ip self.cam_idx = cam_idx def run (self) : mess = "starting thread 'tapo_record' for cam " + self.cam_name + ' (' + self.cam_ip + ')' on_syslog (info, mess, True) p_snap = tapo_snapshot (self.cam_site, self.cam_name, self.cam_ip, self.cam_idx) p_snap.run () url_rtsp = protocol_rtsp + user + ':' + passwd url_rtsp += '@' + self.cam_ip + ':' + str (port_rtsp) + '/stream1' # flux HD} if p_format_video == '.avi' : video_ext = '.avi' cv2_fourcc = cv2.VideoWriter_fourcc(*'XVID') if p_format_video == '.mp4' : video_ext = '.mp4' cv2_fourcc = cv2.VideoWriter_fourcc(*'MP4V') datetime_video = on_horodatage_video () date_video = datetime_video [0:10].replace ('-','') cv2_path_file_video_out = '/home/xxx/TAPO/' + self.cam_name + '-tapo/' + 'record/' cv2_path_file_video_out += 'clip_' + datetime_video + video_ext cv2_window_play = 'Window ' + self.cam_name cam = cv2.VideoCapture(url_rtsp) time.sleep (1) if not cam.isOpened() : mess = "La caméra " + self.cam_name + " n'est pas à l'état open, recommencer" on_syslog (err, mess, True) return video_starting_time = datetime.datetime.utcnow() video_ending_time = video_starting_time + datetime.timedelta(seconds = p_video_recording_duration) result, frame = cam.read() # lecture une trame pour voir caractéristiques if not result : mess = "La caméra " + self.cam_name + " n'est pas à l'état read, recommencer" on_syslog (err, mess, True) return width = int (cam.get(cv2.CAP_PROP_FRAME_WIDTH)) height = int (cam.get(cv2.CAP_PROP_FRAME_HEIGHT)) fps = int (cam.get(cv2.CAP_PROP_FPS)) cv2_fps = fps # même fps in et out cv2_framesize = (width, height) # width et height doivent être des int et non des float sinon erreur framesize overload mess = 'original cam width & height & fps : ' + str (width) + ' ' + str (height) + ' ' + str (fps) on_syslog (info, mess, True) video_out = cv2.VideoWriter(cv2_path_file_video_out, cv2_fourcc, cv2_fps, cv2_framesize) on_syslog (info, 'video out vers fichier : ' + str (cv2_path_file_video_out), True) ''' boucle capture du flux video en provenance de la caméra ''' while float (datetime.datetime.utcnow().timestamp ()) < float (video_ending_time.timestamp ()) : result, frame = cam.read() if not result : break video_out.write (frame) if p_cv2_imshow_motion_recording : cv2.imshow(cv2_window_play, frame) if cv2.waitKey(20) & 0xFF == ord('q'): break cam.release() video_out.release () # fermture du fichier video cv2.destroyAllWindows() # release du lock recording in progress tapo_recording_in_progress_list [self.cam_idx] = False ''' envoi sur pcloud du fichier video suite à détection de mouvement ''' if pcloud_storage_enabled : video_list = [cv2_path_file_video_out] p_upload = tapo_upload_pcloud(video_list, 'video' ) p_upload.start () mess = 'fin de recording pour la caméra ' + self.cam_name on_syslog (info, mess, True) # ---------------------------------------------------------------------------- class tapo_listen (threading.Thread) : def __init__(self, cam_site, cam_name, cam_ip): # le Thread reçoit en paramètre l'url de la radio à diffser threading.Thread.__init__(self) # ne pas oublier cette ligne self.cam_site = cam_site self.cam_name = cam_name self.cam_ip = cam_ip def run (self) : current_thread = threading.current_thread() mess = "starting thread 'tapo_listen' for cam " + self.cam_name + ' (' + self.cam_ip + ')' on_syslog (info, mess, True) mess = ' -> (Thread name = ' + str (current_thread) + ')' on_syslog (info, mess, True) if self.cam_site == 'bcp' : site = '95' if self.cam_site == 'sio' : site = '24' if self.cam_site == 'val' : site = '22' cam_idx = cam_index (self.cam_name) devicemgmt_service = tapo_devicemgmt_service_list [cam_idx] events_service = tapo_events_service_list [cam_idx] ptz_service = tapo_ptz_service_list [cam_idx] media_service = tapo_media_service_list [cam_idx] imaging_service = tapo_imaging_service_list [cam_idx] analytics_service = tapo_analytics_service_list [cam_idx] pullpoint_service = tapo_pullpoint_service_list [cam_idx] notification_service = tapo_notification_service_list[cam_idx] subscription_service = tapo_subscription_service_list[cam_idx] cam_id = self.cam_name + ' (' + self.cam_ip + ') ' mess = 'cam ' + cam_id + ' instance ON (tapo_listen)' on_syslog (info, mess, True) ''' Réception d'un message par le service Events ''' def on_message (msg, cam_idx) : # tous sujets sauf motion détected (sujet IsMotion) message = zeep.helpers.serialize_object(msg, dict) mess = self.cam_name + ' received other message ' + str (message) on_syslog (info, mess, True) ''' récéption des messages de détection de mouvement ''' def on_motion_message (msg, event_count, cam_idx) : mess = '-> proc on_motion_message received message for ' + self.cam_name if adm_message_traced : # msg est de type <class 'zeep.objects.NotificationMessageHolderType'> on_syslog (info, mess, True) message = zeep.helpers.serialize_object(msg, dict) # conversion de l'objet msg de type zeep.object ne type dict topic = message.get ('Topic') topic_value_1 = topic.get ('_value_1') message_1 = message.get ('Message') message_2 = message_1.get ('Message') message_property_operation = message_2.get ('PropertyOperation') message_received_date = message_2.get ('UtcTime') try : message_source = message_2.get ('Source') message_source_simpleitem = message_source.get ('SimpleItem') message_source_simpleitem_value = message_source_simpleitem.get ('Value') message_source_simpleitem_name = message_source_simpleitem.get ('Name') message_source_exists = True except : message_source = None message_source_exists = False try : message_key = message_2.get ('Key') message_key_exists = True except : message_key = None message_key_exists = False message_data = message_2.get ('Data') message_simpleitem = message_data.get ('SimpleItem') message_simpleitem_value = message_simpleitem.get ('Value') message_simpleitem_name = message_simpleitem.get ('Name') # test if is a repeatead message https://www.onvif.org/wp-content/uploads/2017/07/ONVIF_Event_Handling_Test_Specification_v17.06.pdf # 1. test if ***@***.*** = Initialized # 2. repeatedNotification.Topic = topic # 3. repeatedNotification.Source = source (si source element n'est pas vide) # 4. repeatedNotification.Message.Message.Key = key (si key element n'est pas vide) # En détection d'un mouvement tapo on reçoit un burst de messages avec property opération = 'Initialized' ,Name = 'IsMotion' # et Value à True sauf le dernier message où Value =False indiquant la fin de l'initialisation, signal de déclenchement pour le recording' b0 = message_property_operation == 'Initialized' b1 = topic_value_1 == None #last_topic b2 = message_source_exists and message_source_simpleitem_value == 'MyMotionDetectorRule' and message_source_simpleitem_name == 'Rule' #last_message_source b3 = message_key_exists and message_key == None #last_message_key b4 = message_simpleitem_name == 'IsMotion' #last_message_simpleitem_name b5 = message_simpleitem_value == True b6 = message_simpleitem_value == False duplicate = b0 and b1 and b2 and b3 and b4 and b5 if adm_message_traced : mess = '-> ' + self.cam_name + ' message received > ' + 'event_count: ' + str (event_count) #+ ' event_status: ' + event_status mess += ' name: ' + message_simpleitem_name + ' value: ' + str (message_simpleitem_value) mess += ' operation: ' + message_property_operation + ' time: ' + message_received_date on_syslog (info, mess, False) noduplicate = b0 and b1 and b2 and b3 and b4 and b6 if adm_message_traced : print ('>>> boolean ', b0, b1, b2, b3,b4,'duplicate', b5,'noduplicate',b6) if noduplicate : push_text = self.cam_name + ' : mouvement détecté (' + message_simpleitem_name + ') à ' + message_received_date pushover_notification (site, push_text) on_syslog (info, push_text, True) if not tapo_recording_in_progress_list [cam_idx] : try : tapo_recording_in_progress_list [cam_idx] = True tapo_thread = tapo_record (self.cam_site, self.cam_name, self.cam_ip, cam_idx) tapo_thread.start () #time.sleep (1) except Exception as e : mess = 'Exception sur le lancement du thread tapo_recording pour la caméra ' + self.cam_name + li_cr + str (e) on_syslog (info, mess, True) else : mess = 'un enregistrement est déjà en cours pour la caméra ' + self.cam_name on_syslog (info, mess, True) # ----------------------------------------------------------------------------- event_count = 0 # https://deepwiki.com/nirsimetri/onvif-python/5-working-with-onvif-services unsubscribe_done = False ''' boucle attente d'évènement onvif en provenance de la caméra ''' while True : if float (datetime.datetime.utcnow().timestamp ()) < float (ending_subscription_time.timestamp()) : try : messages = pullpoint_service.PullMessages ( Timeout = "PT5S", MessageLimit = 1000) # en fait il semble que PullMessages provoque un event à chaque message current_time = messages.CurrentTime tapo_subscription_termination_time [cam_idx] = messages.TerminationTime ''' Timeout: ISO 8601 duration format (e.g., "PT5S" = 5 seconds, "PT1M" = 1 minute) MessageLimit: Maximum number of messages to return in this call ''' notifications = getattr(messages, "NotificationMessage", None) # s'il y aun seul message notifications est de type srtr et non list if notifications: if not isinstance(notifications, list): notifications = [notifications] if adm_message_traced : mess = 'Pullpoint ' + self.cam_name + ' received a notification list of ' + str (len (notifications)) + ' messages data' on_syslog (info, mess, False) event_count +=1 for msg in notifications: try : mesg = zeep.helpers.serialize_object(msg, dict) mesg_1 = mesg.get ('Message') mesg_2 = mesg_1.get ('Message') mesg_data = mesg_2.get ('Data') mesg_simpleitem = mesg_data.get ('SimpleItem') mesg_name = mesg_simpleitem.get ('Name') if mesg_name == 'IsMotion' : on_motion_message (msg, event_count, cam_idx) else : on_message (msg, cam_idx) except Exception as e : mess = 'Exception message inconnu ' + str(e) on_syslog (err, mess , True) on_message (msg, cam_idx) else : # timeout with no event messages event_count = 0 except Exception as e: mess = 'Exception sur ' + self.cam_name + ' Pullmessages' + li_cr + str (e) on_syslog (err, mess , True ) else : # ending time subscription alloué dépassé if not unsubscribe_done : subscription_service.Unsubscribe () # voir Renew si fonctionnel sinon relancer le programme ou refaire un subcribe complet unsubscribe_done = True tapo_subscription_termination_time [cam_idx] = 'None' mess_admin = ' le temps de souscription pour la caméra ' + self.cam_name + ' est dépassé' pushover_notification (site, mess_admin) on_syslog (err,self.cam_site + mess_admin, True) time.sleep (3600*2) # délai de 2 heures entres les rappels syslog de délai de subscription dépassé # ----------------------------------------------------------------------------- class tapo_commande (threading.Thread) : def __init__(self): threading.Thread.__init__(self) # ne pas oublier cette ligne def run (self) : global term_cd global adm_message_traced term_cmd.open () current_thread = threading.current_thread() mess = "starting thread 'tapo_commande'" on_syslog (info, mess, True ) mess = ' -> (Thread name = ' + str (current_thread) + ')' on_syslog (info, mess, True ) def exec_commande (cmd, cam_name, cam_ip, cam_idx) : global adm_message_traced mess = 'Excuting commande :' + cmd + ' for ' + cam_name + ' (' + cam_ip + ')' on_syslog (info_c, mess, True) devicemgmt_service = tapo_devicemgmt_service_list [cam_idx] events_service = tapo_events_service_list [cam_idx] ptz_service = tapo_ptz_service_list [cam_idx] media_service = tapo_media_service_list [cam_idx] imaging_service = tapo_imaging_service_list [cam_idx] analytics_service = tapo_analytics_service_list [cam_idx] pullpoint_service = tapo_pullpoint_service_list [cam_idx] if cmd == cmd_infosv : lprint ('>>> informations caméra') cam_info = devicemgmt_service.GetDeviceInformation() lprint (cam_info) lprint ('>>> informations réseau') lprint (GetHostnamev, devicemgmt_service.GetHostname()) lprint (GetDNSv, devicemgmt_service.GetDNS()) lprint (GetNTPv , devicemgmt_service.GetNTP()) lprint (GetNetworkInterfacesv, devicemgmt_service.GetNetworkInterfaces()) lprint (GetNetworkDefaultGatewayv, devicemgmt_service.GetNetworkDefaultGateway()) # ----------------------------------------------------------------------------- ''' url rtsp de la camera ''' lprint ('>>> url rtsp de la camera') profile = media_service.GetProfiles()[0] # use the first profile cam_stream_rtsp = media_service.GetStreamUri( ProfileToken=profile.token, StreamSetup={"Stream": "RTP-Unicast", "Transport": {"Protocol": "RTSP"}} ) lprint(cam_stream_rtsp) # ----------------------------------------------------------------------------- ''' operations délivrés par les services ''' if False: lprint(">>> Device Management Operations:") for operation in devicemgmt_service.operations(): lprint(f" - {operation}") lprint("\n>>> Media Operations:") for operation in media_service.operations(): lprint(f" - {operation}") lprint("\n>>> PTZ Operations:") for operation in ptz_service.operations(): lprint(f" - {operation}") lprint("\n>>> Events Operations:") for operation in events_service.operations(): lprint(f" - {operation}") lprint ("\n>>> Events Properties") lprint (GetEventPropertiesv, events_service.GetEventProperties) # ----------------------------------------------------------------------------- ''' savoir si la fonction suivi de mouvement est disponible sur la camera ''' if 'ContinuousMove' in ptz_service.operations(): lprint("PTZ continuous movement is supported") else : lprint("PTZ continuous movement is not supported") # ----------------------------------------------------------------------------- ''' wsdl url ''' lprint (' liste des url wsdl') wsdl_url = devicemgmt_service.GetWsdlUrl () lprint (wsdl_url) # ----------------------------------------------------------------------------- lprint("\n>>> pullpoint Operations:") for operation in pullpoint_service.operations(): lprint(f" - {operation}") # ----------------------------------------------------------------------------- if cmd == cmd_currenttimev : result = devicemgmt_service. GetSystemDateAndTime () #on_syslog (info_c, str (result) , True) result = zeep.helpers.serialize_object(result, dict) # conversion de l'objet result de type zeep.object ne type dict local_date_time = result.get ('LocalDateTime') local_time = local_date_time.get ('Time') local_date = local_date_time.get ('Date') local_hh = str (local_time.get ('Hour')) local_mm = str (local_time.get ('Minute')) local_ss = str (local_time.get ('Second')) local_YY = str (local_date.get ('Year')) local_MM = str (local_date.get ('Month')) local_DD = str (local_date.get ('Day')) local_date_time = 'date et heure pour ' + cam_name + ' : ' local_date_time += local_YY + '-' + local_MM + '-' + local_DD + ' ' local_date_time += local_hh + ':' + local_mm + ':' + local_ss on_syslog (info_c, str (local_date_time) , True) # ----------------------------------------------------------------------------- if cmd == cmd_subscription_TerminationTimev : mess = 'TerminationTime for cam ' + cam_name + ' : ' + str (tapo_subscription_termination_time [cam_idx]) on_syslog (info_c, mess, True) # ----------------------------------------------------------------------------- if cmd == cmd_unsubscribev : try : result = tapo_subscription_service_list[cam_idx].Unsubscribe () tapo_subscription_termination_time [cam_idx] = 'None' on_syslog (info_c, str (result) , True) except Exception as e : on_syslog (err_c, 'error unsubscribe ' + str (e), True) # ----------------------------------------------------------------------------- if cmd == cmd_recording_statev : mess = 'recording state for cam ' + cam_name + ' : ' + str (tapo_recording_in_progress_list [cam_idx]) on_syslog (info_c, mess, True) # ----------------------------------------------------------------------------- if cmd == cmd_rebootv : if p_reboot_enabled : try : result = devicemgmt_service.SystemReboot() on_syslog (info_c, str (result), True) except Exception as e : on_syslog (err_c, 'error reboot ' + str (e), True) else : on_syslog (err_c, 'reboot camera non autorisé', True) # ----------------------------------------------------------------------------- while True : lprint ('[enter] Entrez votre commande') for item in tapo_commandes_list : lprint (item) error = False cmd_num = term_cmd.input ('votre choix : > ') if cmd_num.isdigit() and int (cmd_num) in valide_commande : cmd = tapo_commandes_list [int (cmd_num)-1] cam_command = True if cmd == cmd_set_adm_message_tracedv : adm_message_traced = True on_syslog (info, 'adm_message_traced = ' + str (adm_message_traced), True) cam_command = False if cmd == cmd_reset_adm_message_tracedv : adm_message_traced = False on_syslog (info, 'adm_message_traced = ' + str (adm_message_traced), True) cam_command = False if cam_command : lprint ('[enter] Entrez le numéro de caméra dans la liste' + li_cr ) for i in range (len (tapo_onvif_connected_list)) : lprint (str (i) + '. ' + tapo_cam_list [i]) cam_num = term_cmd.input ('votre choix : > ') if cam_num.isdigit() and int(cam_num) >=0 and int(cam_num) < len (tapo_onvif_connected_list) : cam_name = tapo_onvif_connected_list [int (cam_num)] . split ('/') [1] cam_ip = tapo_onvif_connected_list [int (cam_num)] . split ('/') [2] exec_commande (cmd , cam_name, cam_ip, int (cam_num)) else : error = True else : error = True if error : lprint ('>>> commande invalide') time.sleep (3) # attendre la réponse avant de réafficher le menu ''' ------------ main -------------- ''' p = coloring () get_pass () # compte des caméras ''' définition de la période de souscription à Pullmessages pour recevoir les messages (notifications) en provenance des caméras ''' starting_subscription_time = datetime.datetime.utcnow() if p_subscription_duration_unit == 'H' : ending_subscription_time = starting_subscription_time + datetime.timedelta(hours= p_subscription_duration) subscribe_initial_time = 'PT' + str (p_subscription_duration) + 'H' if p_subscription_duration_unit == 'M' : ending_subscription_time = starting_subscription_time + datetime.timedelta(minutes=p_subscription_duration) subscribe_initial_time = 'PT' + str (p_subscription_duration) + 'M' mess = 'starting with parameters' + li_cr mess+= ' - environememt ; ' + p_env + li_cr mess+= ' - video recording duration : ' + str (p_video_recording_duration) + li_cr mess+= ' - format video : ' + p_format_video + li_cr mess+= ' - snapshots : ' + str (p_nb_snapshots) + li_cr mess+= ' - subscription duration : ' + str (p_subscription_duration) + li_cr mess+= ' - subscription duration units : ' + p_subscription_duration_unit + li_cr mess+= ' - subscribe initial time : ' + subscribe_initial_time + li_cr mess+= ' - expiration subscription : ' + str (ending_subscription_time) + li_cr mess+= ' - arg OnvifClient capture_XML : ' + str (p_ONVIFClient_capture_xml) + li_cr mess+= ' - cv2 imshow recording motion : ' + str (p_cv2_imshow_motion_recording) + li_cr mess+= ' - reboot_camera_enabled : ' + str (p_reboot_enabled) on_syslog (info, mess, True) ''' initialisation du client ONVIF instanciation des services onvif associés à chaque caméra ''' cam_num = -1 for tapo_cam in tapo_cam_list: tapo_tup = tapo_cam.split ('/') tapo_site = tapo_tup [0] tapo_name = tapo_tup [1] tapo_ip = tapo_tup [2] tapo_room = tapo_tup [3] cam_id = tapo_name + ' (' + tapo_ip + ') ' capture_xml = True if p_ONVIFClient_capture_xml else False result= False try : cam = ONVIFClient(tapo_ip, port_onvif, user, passwd, timeout = 20, capture_xml = capture_xml, cache = CacheMode.ALL ) result = True except Exception as e : result = False mess = 'Exception sur création ONVIFclient pour ' + cam_id + li_cr + str (e) on_syslog (err, mess, True) if result : cam_num +=1 tapo_onvif_connected_list .append (tapo_cam) tapo_onvifclient_list .append (cam) tapo_devicemgmt_service_list.append (cam.devicemgmt()) tapo_events_service_list .append (cam.events()) tapo_ptz_service_list .append (cam.ptz()) tapo_media_service_list .append (cam.media ()) tapo_imaging_service_list .append (cam.imaging ()) tapo_analytics_service_list .append (cam.analytics ()) ''' essai de répartir les # topic filter , voir https://deepwiki.com/nirsimetri/onvif-python/5.4-events-and-pull-point-subscriptions chapitre Filtered Subscription filter_expr = tapo_events_service_list [cam_num].type('CreatePullPointSubscription') # filtrage des sujets sur motion topic filter_expr.Filter = { "TopicExpression": { "Dialect": "http://www.onvif.org/ver10/tev/topicExpression/ConcreteSet", "_value_1": "tns1:RuleEngine/MotionDetection" } } subscription_ref = tapo_events_service_list [cam_num].CreatePullPointSubscription (Filter = filter_expr, InitialTerminationTime = subscribe_initial_time) ''' try : subscription_ref = tapo_events_service_list [cam_num].CreatePullPointSubscription (InitialTerminationTime = subscribe_initial_time) mess = 'CreatePullPointSubscription OK for cam ' + cam_id on_syslog (info, mess, True) subscription_result = True except Exception as e : mess = 'CreatePullPointSubscription failed for cam ' + cam_id on_syslog (err, mess, True) on_syslog (err, str(e), True) subscription_result = False if subscription_result : tapo_pullpoint_service_list . append (cam.pullpoint (subscription_ref)) tapo_notification_service_list . append (cam.notification()) tapo_subscription_service_list . append (cam.subscription(subscription_ref)) tapo_subscription_termination_time.append (subscribe_initial_time) tapo_recording_in_progress_list.append (False) else : # la caméra n' pas réussi la création de son pullpoint on ne pourra pas recevoir ses messages tapo_onvif_connected_list .pop () tapo_onvifclient_list .pop () tapo_devicemgmt_service_list.pop () tapo_events_service_list .pop () tapo_ptz_service_list .pop () tapo_media_service_list .pop () tapo_imaging_service_list .pop () tapo_analytics_service_list .pop () cam_num = cam_num-1 ''' --------------------------------------------------------------------------- lancement des threads tapo_listen pour chaque caméra, écoute des messages en provenance des caméras lancement du thread tapo_commande qui permet de lancer des commandes onvif aux caméras --------------------------------------------------------------------------- ''' len_list = len(tapo_onvif_connected_list) if len_list > 0 : for tapo_cam in tapo_onvif_connected_list : tapo_tup = tapo_cam.split ('/') tapo_site = tapo_tup [0] tapo_name = tapo_tup [1] tapo_ip = tapo_tup [2] tapo_room = tapo_tup [3] tapo_thread = tapo_listen(tapo_site, tapo_name, tapo_ip) tapo_thread.name = 'Tapo-ONVIF-listen-' + tapo_name tapo_thread.start () time.sleep (2) if len_list > 0 : time.sleep (3) term_cmd = WindowTerminal.create_window () tapo_thread = tapo_commande () tapo_thread.name = 'Tapo-ONVIF-commandes' tapo_thread.start ()

[kaburagisec]

Okay, I will try debugging locally, because I also have a TP Link TAPO C210, if there is a solution there will be a PR as usual and a new release for this library.