ZTh'HUdZddlmZddlmZddlmZmZmZmZm Z m Z m Z m Z ddl ZddlmZddlmZmZddlmZdd lmZdd lmZdd lmZdd lmZGd dZ e e e e effZ!de"d<GddZ#GddZ$GddZ%Gdde Z&GddZ'y)a& Module containing utilities to construct a data query which is ultimately passed to `sift_py.data.service.DataService.execute` to download telemetry. This module also contains types that represent the result of a data query which can be easily converted into a `pandas` data frame or series. ) annotations)datetime)AnyDictListOptionalTuple TypedDictUnioncastN) Timestamp) NotRequired TypeAlias) channel_fqn)to_timestamp_nanos)ChannelTimeSeries)_component_deprecation_warning)ChannelDataTypecveZdZUdZdZded<ded<ded<ded <ded <d ed <d ef ddZy) DataQuerya A query that is meant to be passed to `sift_py.data.service.DataService.execute` to retrieve telemetry. - `asset_name`: The name of the asset to query telemetry for. - `start_time`: The start time of the time range of the data to request. - `end_time`: The end time of the time range of the data to request. - `sample_ms`: The sampling rate to use when retrieving data. The lower the sampling rate, the greater the data-fidelity. A sampling rate of `0` retrieves full-fidelity data. - `channels`: List of either `ChannelQuery` or `CalculatedChannelQuery`, but not both. Represents the channels to retrieve data from. istr asset_namez pd.Timestamp start_timeend_timeint sample_ms page_size1List[Union[ChannelQuery, CalculatedChannelQuery]]channelsrct||_t||_||_||_||_|j j|_yN) rrrrrr __class__DEFAULT_PAGE_SIZEr)selfrrrrr_s W/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/sift_py/data/query.py__init__zDataQuery.__init__2sB-Z8*84 $"  99N) rrr4Union[pd.Timestamp, TimestampPb, datetime, str, int]rr)rrrrr%r)__name__ __module__ __qualname____doc__r#__annotations__r'r(r&rrsz  ONN??"::I:G : D :  : :r(rrChannelLookupInfoc<eZdZUdZded<d dZd dZd dZd dZy) DataQueryResultzI The result of a data query which can contain multiple channels. "Dict[str, List[ChannelTimeSeries]]_resultc||_yr!)r4)r$merged_channel_datas r&r'zDataQueryResult.__init__Rs * r(cL|j|}t|dkDr|dSy)zL Like `channels` but returns a single `DataQueryResultSet`. rN)rlen)r$lookupresults r&channelzDataQueryResult.channelUs* v& v;?!9 r(c g}|D]t}t|tr~|jj|}|s2t |dkDrt d|dt |d|d}|j t||j|jttttf|\}}|d|j}|jj|}|st |dk(r8|d}|j t||j|j+|D]E}|j|k(s|j t||j|jtw|S)a8 Returns a `sift_py.data.channel.ChannelTimeSeries` given the `lookup` argument. If a `lookup` is a fully qualified name (FQN) `str` and there are multiple channels with the same FQN, this will raise a `ValueError`. In these situations, `lookup` must be a tuple where the first item is the channel FQN and the second the `sift_py.ingestion.channel.ChannelDataType`. If `lookup` is a tuple, then the channel data-type will be appended to the key referencing the `sift_py.data.channel.ChannelTimeSeries`. zAmbiguous lookup provided: 'z' is associated with z channels.r identifier timestampsvalues.) isinstancerr4getr8 ValueErrorappendDataQueryResultSet time_column value_columnr r r as_human_str data_type) r$r9r:info time_seriesseriesfqnrKr?s r&rzDataQueryResult.channelsas,./ D$$"ll..t4 "{#a'$6tf%?@ "ll..s3 "{#q((^FMM*'1'-'9'9#)#6#6) F''94 .+5+1+=+='-':': M/ b r(c g}|jjD]\}}t|dkDrZ|D]T}|jj }|d|}|j t ||j|jVn|D]3}|j t ||j|j5|S)z+ Returns all channel data. r=rBr>) r4itemsr8rKrJrFrGrHrI)r$r:rOrMrNhuman_data_type fqn_extendeds r& all_channelszDataQueryResult.all_channelss  $ 2 2 4  C;!#) F&,&6&6&C&C&EO&)U!O+<#=LMM*'3'-'9'9#)#6#6 %  &#&#)#5#5%22  0 r(N)r6r3)r9r0returnzOptional[DataQueryResultSet])r9r0rUList[DataQueryResultSet])rUrV) r*r+r,r-r.r'r;rrTr/r(r&r2r2Ks$0/+ ?Br(r2cdeZdZUdZded<ded<ded<d dZddd Zddd Z d dd Zy )rGz Represents time series data for a single channel. Can easily be converted into a `pandas` data frame like so: ```python pd.DataFrame(data_query_result_set.all_columns()) ``` rr?List[pd.Timestamp]r@ List[Any]rAc.||_||_||_yr!r>)r$r?r@rAs r&r'zDataQueryResultSet.__init__s$$ r(NcR||j|jiS||jiS)z Returns a single key-value pair dictionary meant to represent the value column of the data-set. `column_name` can be used to override the name of the column. )r?rAr$ column_names r&rIzDataQueryResultSet.value_columns,  OOT[[1 1- -r(c>|d|jiS||jiS)z Returns a single key-value pair dictionary meant to represent the time column of the data-set. `column_name` can be used to override the name of the column. time)r@r\s r&rHzDataQueryResultSet.time_columns(  DOO, ,1 1r(ch|j|}|j|j||S)zd Returns both the time and value columns with options to override the column names. )rHupdaterI)r$time_column_namevalue_column_namecolss r&columnszDataQueryResultSet.columnss2 01 D%%&789 r()r?rr@rXrArYr!)r] Optional[str]rUDict[str, List[Any]]NN)rbrfrcrfrUrg) r*r+r,r-r.r'rIrHrer/r(r&rGrGsRO""  .2+/+/ ' )   r(rGcPeZdZUdZded<ded<ded< d d dZd d Zy) ChannelQueryzW Represents a single channel to include in the `sift_py.data.query.DataQuery`. r channel_namerf componentrun_nameNcp||_|&tt|j||_||_y)N)namerl)rkrrrm)r$rkrlrms r&r'zChannelQuery.__init__s4 )  * , +1B1Bi XD   r(c,t|jSr!)rrk)r$s r&rOzChannelQuery.fqns4,,--r(rh)rkrrlrfrmrf)rUr)r*r+r,r-r.r'rOr/r(r&rjrjsI $("& ! !! ! !.r(rjc6eZdZUded<ded<ded<ded<y) ExpressionChannelReferencer referencerkzNotRequired[str]rlzNotRequired[ChannelDataType]rKN)r*r+r,r.r/r(r&rrrrsN++r(rrcTeZdZUdZded<ded<ded<ded< d d d Zy ) CalculatedChannelQueryzb Represents a single calculated channel to include in the `sift_py.data.query.DataQuery`. r channel_key expression List[ExpressionChannelReference]expression_channel_referencesrfrmNc<||_||_||_||_yr!)rvrmrwry)r$rvrwryrms r&r'zCalculatedChannelQuery.__init__$s"'  $-J*r(r!)rvrrwrryrxrmrf)r*r+r,r-r.r'r/r(r&rurusVO#CC#' K K K(H K  Kr(ru)(r- __future__rrtypingrrrrr r r r pandaspdgoogle.protobuf.timestamp_pb2r TimestampPbtyping_extensionsrrsift_py._internal.channelrsift_py._internal.timersift_py.data._channelr sift_py.errorrsift_py.ingestion.channelrrrr0r.r2rGrjrrrur/r(r&rs#KKKB415385(:(:V %S%_0D*E%EF9Fvvr33l..2,,KKr(