Skip to content

20-UseCase

Nevados
Refer: https://taosdata.feishu.cn/wiki/Zkb2wNkHDihARVkGHYEcbNhmnxb
path: cases/18-StreamProcessing/20-UseCase/big_press.py

IDMP nevados
Refer: https://taosdata.feishu.cn/wiki/XaqbweV96iZVRnkgHLJcx2ZCnQf
path: cases/18-StreamProcessing/20-UseCase/nevados_dbg.py

Stream sdny test
1. test sdny stream
path: cases/18-StreamProcessing/20-UseCase/sdny_2.py

Basic: primary key test
1. Create tables with primary key
2. Create stream
3. Test result
path: cases/18-StreamProcessing/20-UseCase/test_6771200393.py

IDMP: meters scenario
1. IDMP trigger table is super vtable
2. IDMP trigger table is vtable
3. IDMP trigger mode: period, sliding, event, session, interval, count, state
4. IDMP trigger group: partition by tbname, tag column, tbname and columns
5. IDMP trigger condition: on window open, on window close, on event
6. IDMP trigger action: notify, calc, calc and notify
7. IDMP notify on: window open, window close, both open and close
8. IDMP output table: super table , normal table
9. IDMP stream Options: IGNORE_DISORDER, CALC_NOTIF_ONLY, LOW_LATENCY_CALC,PRE_FILTER, FORCE_OUTPUT, IGNORE_NODATA_TRIGGER
Refer: https://taosdata.feishu.cn/wiki/Zkb2wNkHDihARVkGHYEcbNhmnxb
path: cases/18-StreamProcessing/20-UseCase/test_idmp_meters.py

IDMP: public utility scenario
Reproduce the scenario where IDMP generates a core: create 2 streams, STOP STREAM, START STREAM, DROP STREAM
path: cases/18-StreamProcessing/20-UseCase/test_idmp_public.py

IDMP: photovoltaic scenario
1. Test the analysis generated by AI recommendations, create a Stream, and verify the correctness of the stream.
2. Test different trigger types:
1. Sliding window: Calculate aggregates over an m-hour period every n minutes.
2. Event window: Starts from the start_condition and ends at the stop_condition for a field.
3. Session window: No data reported for more than n minutes.
4. Count window: Collect data n times consecutively.
3. Different types of aggregate functions:
1. AVG: Average value
2. LAST: Latest value
3. SUM: Summation
4. MAX: Maximum value
Refer: https://taosdata.feishu.cn/wiki/Zkb2wNkHDihARVkGHYEcbNhmnxb#share-Ygqld907hoMESmx04GBcRlaVnZz
path: cases/18-StreamProcessing/20-UseCase/test_idmp_pv.py

IDMP: tobacco scenario
1. Test the analysis generated by AI recommendations, create a Stream, and verify the correctness of the stream.
2. Test manually created analysis and verify the correctness of the stream.
2.1. Trigger types:
- Timed window: Specify different window sizes and window offsets.
- State window: Specify the field for the state.
- Session window: Specify the time interval for the session.
2.2. Time window aggregation:
- Window start time: _tprev_localtime / _twstart / _tprev_ts
- Window end time: _tlocaltime / _twend / _tcurrent_ts
2.3. Output attributes:
- AVG: Average value
- LAST: Latest value
- SUM: Summation
- MAX: Maximum value
- STDDEV: Standard deviation
- SPREAD: Range
- SPREAD/FIRST: Rate of change
Refer: https://taosdata.feishu.cn/wiki/Zkb2wNkHDihARVkGHYEcbNhmnxb#share-I9GwdF26PoWk6uxx2zJcxZYrn1d
path: cases/18-StreamProcessing/20-UseCase/test_idmp_tobacco.py

IDMP: vehicle scenario
1. IDMP stream option with EVENT_TYPE
2. IDMP stream option with MAX_DELAY
3. IDMP stream option with WATERMARK
4. IDMP stream option with EXPIRED_TIME
5. IDMP stream option with IGNORE_DISORDER
6. IDMP write data with ordered and disordered data
7. IDMP write NULL data
8. IDMP calc with trows and select sql
Refer: https://taosdata.feishu.cn/wiki/Zkb2wNkHDihARVkGHYEcbNhmnxb
path: cases/18-StreamProcessing/20-UseCase/test_idmp_vehicle.py

IDMP: YuXi scenario
Refer: https://taosdata.feishu.cn/wiki/G8mSwPK20iLpPrk9MmOc9g95nLe
path: cases/18-StreamProcessing/20-UseCase/test_idmp_yuxi.py

Nevados
Refer: https://taosdata.feishu.cn/wiki/XaqbweV96iZVRnkgHLJcx2ZCnQf
path: cases/18-StreamProcessing/20-UseCase/test_nevados.py