ZThg ddlmZddlmZddlmZmZmZmZddlm Z ddl m Z ddl m ZddlmZddlmZdd lm Z mZmZGd d eZ Gd d eZGddeZy)) annotations)datetime)DictListType TypedDict) IngestWithConfigDataChannelValue) ChannelConfig) FlowConfig)Self) AsProtobuf)r ChannelValue channel_fqncReZdZUdZded<ded<ded<d dZd d Zedd Zy )r ax Describes a flow which is a set of channels whose values are often ingested together, allowing users to send multiple data points for multiple channels in a single request. `channel_by_fqn`: A mapping of a channel's fully-qualified name to the index of the `sift_py.ingestion.channel.ChannelConfig` as it appears in the `channels` attribute. strnameList[ChannelConfig]channelszDict[str, int]channel_by_fqnc||_||_t|Dcic]\}}t||c}}|_ycc}}w)N)rr enumeraterr)selfrrics [/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/sift_py/ingestion/flow.py__init__zFlowConfig.__init__!s8   =Fx=PQTQ{1~q0QQs=c ||j|jDcgc]}|jtc}Scc}wN)rr)rras_pbChannelConfigPb)rklassconfs rrzFlowConfig.as_pb&s4>BmmLddjj1L  LA c ||j|jDcgc]}tj|c}Scc}wr)rrr from_pb)clsmessagers rr%zFlowConfig.from_pb,s88?8H8HI1m++A.I  Ir#N)rrrr)r!zType[FlowConfigPb]return FlowConfigPb)r'r)r(r ) __name__ __module__ __qualname____doc____annotations__rr classmethodr%rr r s9 I!!""R    r1r c0eZdZUdZded<ded<ded<y) FlowaU Represents a single flow that will be sent to Sift. Because this class uses `sift_py.ingestion.channel.ChannelValue` which is a fully qualified channel value, a specific ordering of items in `channel_values` is not required. If a particular flow has 5 channels, it is okay to send only data for 3 channels using this class. r flow_namer timestampzList[ChannelValue]channel_valuesNr*r+r,r-r.r0r1rr3r34s N&&r1r3c0eZdZUdZded<ded<ded<y) FlowOrderedChannelValuesap Represents a single flow that will be sent to Sift. Unlike `sift_py.ingestion.flow.Flow`, this class requires that the ordering of channel values in `channel_values` match what the flow associated with `flow_name` expects. If a channel doesn't have particular data to send for a particular time, `sift_py.ingestion.channel.empty_value` should be used rr4rr5z&List[IngestWithConfigDataChannelValue]r6Nr7r0r1rr9r9@s N::r1r9N) __future__rrtypingrrrrsift.ingest.v1.ingest_pb2r /sift.ingestion_configs.v2.ingestion_configs_pb2r r r r)typing_extensionsr "sift_py._internal.convert.protobufr sift_py.ingestion.channelrrr3r9r0r1rrAsQ"..F#9NN  B '9 ' ;y ;r1