Definición del modelo de ThingWorx en Composer > Modelado > Fragmentos de código > QueryStreamEntriesWithData
QueryStreamEntriesWithData
Descripción
Este servicio se puede utilizar para consultar entradas de flujo en función de los parámetros de entrada especificados. El resultado contendrá el ID de entrada, la ubicación, el origen, el tipo de origen, las etiquetas de datos, la fecha y los campos definidos en la definición de datos asociada 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
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.
STRING
tags
Etiquetas de datos asociadas a la entrada de flujo.
TAGS
sourceTags
Etiquetas de modelo asociadas al origen de esta entrada.
TAGS
startDate
Fecha y hora posteriores a la creación de la entrada de flujo.
DATETIME
endDate
Fecha y hora anteriores a la creación de la entrada de flujo.
DATETIME
oldestFirst
Recuperar de los registros más antiguos o más recientes. Por defecto, este valor 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
Se devuelve una infotable en la que se incluyen el ID de entrada, la ubicación, el origen, el tipo de origen, las etiquetas de datos, 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 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 el ID de entrada, la ubicación, el origen, el tipo de origen, las etiquetas de datos de la entrada de flujo, la fecha y hora, Property1, Property2 y Property3:
result = Things["TestStream"].QueryStreamEntriesWithData({
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?