Flujos
Los flujos representan datos de series temporales. Por consiguiente, cada flujo tiene una fecha y hora, así como campos adicionales. Un flujo de ThingWorx es una lista de actividades de cosas o datos asociados con cosas. Un flujo puede considerarse como una estructura de tabla con cinco campos predefinidos y cualquier número de campos definidos por el usuario. En cada entrada del flujo se incluyen los siguientes campos:
• Timestamp
La hora en que se ha creado la entrada. También es posible proporcionar una fecha y hora al añadir una entrada de flujo.
 |
La fecha y hora corresponden a un campo clave para los flujos. Si se añade una entrada con la misma fecha y hora, se sobrescribirán la fecha y hora anteriores (upsert). Para evitarlo, especifique los milisegundos para la fecha y hora.
|
|
|
Al filtrar datos de flujo de los flujos DSE, la fecha de fin no es inclusiva. Por ejemplo, si se consultan entradas y se define la fecha de fin en la fecha y hora exactas de la última entrada, la última entrada no se incluirá en los resultados.
|
• Tag
Cada entrada de flujo puede tener etiquetas de datos. Las etiquetas de datos ayudan a encontrar y consumir datos específicos de tiempo de ejecución.
• Source
El origen de la entrada de flujo. Normalmente es el nombre de la cosa que escribe en el flujo o un identificador de un sistema externo. Hay una relación establecida entre un flujo y su origen. Esto forma parte de las relaciones integradas en las que se puede buscar y que son un artefacto del modelo.
|
|
Si se utiliza DataStax Enterprise (DSE) como proveedor de persistencia y se utiliza el servicio UpdateStreamEntry con un objeto source diferente del que se ha utilizado inicialmente, la entrada no se actualizará para reflejar el nuevo objeto source. El origen inicial se conserva en el registro para cumplir con lo que se ha generado la clave principal.
|
• SourceType
El tipo de entidad del origen.
• Location
La ubicación del origen de la entrada de flujo.
|
|
En PostgreSQL y H2, en las entradas de flujo se incluyen entradas de clave única de timestamp y source.
|
Además de los campos incluidos, se pueden configurar campos adicionales. Una definición de datos de ThingWorx define los campos adicionales. Estos valores de campo se conocen como valores de flujo.
Esto también gobierna los servicios StreamEntries, StreamData y StreamEntriesWithData. En estos servicios:
• StreamEntries: campos por defecto
• StreamData: campos de definición de datos
• StreamEntriesWithData: todos los campos del flujo
Si se
utiliza DataStax Enterprise (DSE) como proveedor de persistencia, se puede configurar lo siguiente en :
|
Nombre
|
Valor por defecto
|
|---|---|
|
Número de buckets de origen
|
1000
|
|
Número de buckets por período de tiempo (horas)
|
24
|