Fi/ ddlZddlZddlZddlmZddlmZddlmZm Z ddl m Z m Z ddl mZmZmZmZmZmZmZmZddlmZddlmZdd ed ed ed dfd ZGddZeZy)N)Path)Thread)Requesturlopen)SETTINGS __version__)ARGV ENVIRONMENTGITIS_PIP_PACKAGEONLINEPYTHON_VERSIONRANK TESTS_RUNNING)GITHUB_ASSETS_NAMES) get_cpu_infourldatatimeoutreturnc tj|dj}t||ddi}t ||j y#t $rYywxYw)z"Send a one-shot JSON POST request.),:) separatorsz Content-Typezapplication/json)rheaders)rN)jsondumpsencoderrclose Exception)rrrbodyreqs Z/var/www/pod-logistic/pod-ai/venv/lib/python3.12/site-packages/ultralytics/utils/events.py_postr$sY zz$:6==?c~?Q.RSW%++-    sAA AAc&eZdZdZdZddZdddZy)EventsaCollect and send anonymous usage analytics with rate-limiting. Event collection and transmission are enabled when sync is enabled in settings, the current process is rank -1 or 0, tests are not running, the environment is online, and the installation source is either pip or the official Ultralytics GitHub repository. Attributes: url (str): Measurement Protocol endpoint for receiving anonymous events. events (list[dict]): In-memory queue of event payloads awaiting transmission. rate_limit (float): Minimum time in seconds between POST requests. t (float): Timestamp of the last transmission in seconds since the epoch. metadata (dict): Static metadata describing runtime, installation source, and environment. enabled (bool): Flag indicating whether analytics collection is active. Methods: __init__: Initialize the event queue, rate limiter, and runtime metadata. __call__: Queue an event and trigger a non-blocking send when the rate limit elapses. zihttps://www.google-analytics.com/mp/collect?measurement_id=G-X8NCJYTQXM&api_secret=QLQrATrNSwGRFRLE-cbHJwNc g|_d|_d|_ttdj dk(t jrdn trdndtjdd dtttttjd zd d |_t"d xr6t$dvxr,t& xr#t(xrtxst j*dk(|_y)zRInitialize the Events instance with queue, rate limiter, and environment metadata.g>@gryologitpipother.g4&k Ci)cliinstallpythonCPUversionenv session_idengagement_time_msecsync>rz.https://github.com/ultralytics/ultralytics.gitN)events rate_limittrr namer is_repor rrsplitrrr roundrandommetadatarrrr originenabled)selfs r#__init__zEvents.__init__0s Q=%%/ # u.g$++C3A6>" $ 67$(    V  c c!! c c a3::1a#a c|jsyt|jdkri|j|j|j t vr |j ndt|d}|jdk(r|j|d<|jdk(r|t|jnd|d<|jj|j|d tj}||jz |jkryt!|j}t#t$|j&t(d |d fd j+g|_||_y)aQueue an event and flush the queue asynchronously when the rate limit elapses. Args: cfg (IterableSimpleNamespace): The configuration object containing mode and task information. device (torch.device | str, optional): The device type (e.g., 'cpu', 'cuda'). backend (object | None, optional): The inference backend instance used during prediction. Ncustom)taskmodeldeviceexportformatpredictbackend)r;paramsuuid) client_idr8T)targetargsdaemon)rBlenr8r@rIrJrstrmoderMtype__name__appendtimer:r9listrr$rrstart)rCcfgrKrOrPr:payload_eventss r#__call__zEvents.__call__Hs,||  t{{ b --&)ii3F&FHf+ F xx8##&::x xx9$>E>QDM$:$:W[y! KK  FC D IIK J$// ) dkk*(((6*:nUV  %' rE)rN)NN)rZ __module__ __qualname____doc__rrDrarEr#r&r&s& vC 0)rEr&)g@) rr?r\pathlibr threadingrurllib.requestrr ultralyticsrrultralytics.utilsr r r r r rrrultralytics.utils.downloadsrultralytics.utils.torch_utilsrrWdictfloatr$r&r8rerEr#rosb +-qqq;6 s $   WWt rE