Definición del modelo de ThingWorx en Composer > Modelado > Fragmentos de código > QueryStreamData
QueryStreamData
Descripción
Este servicio se puede utilizar para consultar las entradas de flujo en función de los parámetros de entrada especificados. La consulta y el filtro son similares a QueryStreamEntriesWithData; sin embargo, la infotable resultante solo contiene la fecha y los campos definidos en la definición de datos asociados al flujo.
Entradas
Nombre del parámetro
Descripción
Tipo base
maxItems
Número máximo de elementos que se devolverán en el conjunto de resultados. El valor por defecto es 500. Este parámetro se aplica después de aplicar todos los otros filtros.
NUMBER
source
El origen de la entrada de flujo. Cuando se creó la entrada de flujo, se debería haber seleccionado un objeto source_type válido. Este origen puede tener etiquetas de modelo asociadas.
STRING
tags
Las etiquetas de datos asociadas a la entrada de flujo.
TAGS
sourceTags
Las etiquetas de modelo asociadas al origen de esta entrada.
TAGS
startDate
Fecha y hora después de la cual se creó la entrada de flujo.
DATETIME
endDate
Fecha y hora antes de la cual se creó la entrada de flujo.
DATETIME
oldestFirst
Recuperar de los registros más antiguos o más recientes. El valor por defecto es false.
BOOLEAN
query
Los criterios de consulta para filtrar datos.
Para obtener más información, consulte Parámetro de consulta para servicios de consulta.
QUERY
Salida
Nombre del parámetro
Descripción
Tipo base
result
Devuelve una infotable en la que se incluyen la fecha y hora y los campos definidos en la definición de datos asociada con el flujo.
INFOTABLE
Ejemplo
En el siguiente ejemplo, TestStream tiene una definición de datos que tiene los campos Property1, Property2 y Property3.
Entidad
ModelTags
Administrator
System
Thing1
{vocabulary: "MT1", vocabularyTerm: "MT1-MTerm1"}
entry_id
source
source_type
location
Etiquetas de datos
Property1
Property2
Property3
1
System
Usuario
1
2
3
2
Administrator
Usuario
a
b
c
3
Thing1
Cosa
{vocabulary: "DataTag1", vocabularyTerm: "DT1-Term1"}
1
2
3
4
AAA
Desconocido
aa
bb
cc
5
Thing1
Cosa
{vocabulary: "DataTag1", vocabularyTerm: "DT1-Term1"}
1
2
3
En el siguiente ejemplo se muestra una consulta para entradas de flujo utilizando todos los parámetros soportados. Con esta llamada de API se devuelve una infotable en la que se incluyen la fecha y hora, Property1, Property2 y Property3:
result = Things["TestStream"].QueryStreamData({
maxItems: 50,
source: 'Thing1',
tags: "DataTag1:DT1-Term1", /* Data tags on Stream Entry */
sourceTags: "MT1:MT1-MTerm1", /* Model tags on Source entity */
startDate: new Date(new Date().setFullYear(new Date().getFullYear() - 1)),
endDate: Date.now(),
oldestFirst: false,
query: "{ \"sorts\": [{\"fieldName\": \"Property1\"}]}"
});
¿Fue esto útil?