FB_NoSQLQueryBuilder_TimeSeriesDB

Funktionsbaustein zum Definieren einer Abfrage einer TimeSeries Datenbank. Die Abfrage wird mit dem FB_NoSQLQueryEvt abgeschickt. Das Aufrufen der Methode Build ist nicht notwendig. Datenstrukturen können dabei mit Attributen beschrieben werden, um individuelle Einstellungen zu treffen.

Eingänge

Name	Type	Beschreibung
pQueryOptions	POINTER TO BYTE	Gibt die Adresse zu den Query Optionen an.
cbQueryOptions	UDINT	Länge der Query Optionen.

Syntax

Definition:

FUNCTION BLOCK FB_NoSQLQueryBuilder_TimeSeriesDB
VAR_INPUT
    pQueryOptions : POINTER TO BYTE;
    cbQueryOptions : UDINT;
END_VAR
VAR_OUTPUT
END_VAR

Methoden

Name	Definitionsort	Beschreibung
Build	Lokal	[optional] Diese Methode generiert aus den eingestellten Parametern eine Abfrage für den FB_NoSQLQueryEvt.

Bespiel:

VAR
    fbNoSQLQueryBuilder_TimeSeriesDB : FB_NoSQLQueryBuilder_TimeSeriesDB;
    QueryOption_TSDB_Insert : T_QueryOptionTimeSeriesDB_Insert;
    fbNoSqlQueryEvt : FB_NoSQLQueryEvt(sNetID := '', tTimeout := T#15S);
    MyStructArray: ARRAY[1..1000] OF MyStruct;
END_VAR

CASE nState OF 
    1: // init 
        fbNoSQLQueryBuilder_TimeSeriesDB.pQueryOptions := ADR(QueryOption_TSDB_Insert);
        fbNoSQLQueryBuilder_TimeSeriesDB.cbQueryOptions := SIZEOF(QueryOption_TSDB_Insert);

        QueryOption_TSDB_Insert.sTableName := 'MeasurementName';
        QueryOption_TSDB_Insert.sDataType := 'MyStruct';
        QueryOption_TSDB_Insert.pSymbol := ADR(MyStructArray);
        QueryOption_TSDB_Insert.cbSymbol := SIZEOF(MyStructArray);
        QueryOption_TSDB_Insert.nDataCount := 1000; // ArrayLength
        QueryOption_TSDB_Insert.nStartTimestamp := F_GetSystemTime(); // get current twincat time 
        QueryOption_TSDB_Insert.nCycleTime := 1000; // equivalent to 1 ms

    2: // write values 
        IF fbNoSqlQueryEvt.Execute(dbid, fbNoSQLQueryBuilder_TimeSeriesDB) THEN
            IF fbNoSqlQueryEvt.bError THEN
                // do some error handling here
            ELSE
                // success
            END_IF
        END_IF
END_CASE

Voraussetzungen

Entwicklungsumgebung	Zielplattform	Einzubindende SPS Bibliotheken
TwinCAT v3.1 Build 4022.20	PC oder CX (x86)	Tc3_Database

Weiterführende Informationen

Build