Definición del modelo de ThingWorx en Composer > Sistema > Registros > Registros del procesador de flujo
Registros del procesador de flujo
Para ayudar a supervisar la capacidad de colas del procesador de flujo, se han añadido nuevos registros de nivel de aviso para cada procesador de flujo. Estos registros de aviso comenzarán a aparecer en los registros de aplicación si alguna de las colas individuales está al 70 % de su capacidad o más. Para los procesadores de flujos de valor, tablas de datos y flujos, si la cola ha alcanzado su capacidad máxima, se rechazará todo intento de añadir una entrada a las colas. Para el procesador de propiedades persistentes, se volverá a intentar (con Tiempo de espera del productor) añadir la entrada a la cola y después del tiempo de espera de reintento, si la entrada no se hubiera podido añadir, esta se rechazará. Las entradas rechazadas se cuentan según las nuevas métricas de totalWritesRejected mencionadas anteriormente.
A continuación se muestra un ejemplo de estas sentencias de registros.
PersistentPropertyProcessor
2022-02-09 02:56:15.465+0000 [L: WARN] [O: c.t.p.p.StreamEntryProcessor] [I: ] [U: ] [S: ] [P: ] [T: Timer-6] PersistentPropertyProcessor queue #9 is currently 82.0 percent full that is at or above 70.0 percent threshold
82022-02-09 02:56:15.465+0000 [L: WARN] [O: c.t.p.p.StreamEntryProcessor] [I: ] [U: ] [S: ] [P: ] [T: Timer-6] PersistentPropertyProcessor queue #11 is currently 82.0 percent full that is at or above 70.0 percent threshold
92022-02-09 02:56:15.465+0000 [L: WARN] [O: c.t.p.p.StreamEntryProcessor] [I: ] [U: ] [S: ] [P: ] [T: Timer-6] PersistentPropertyProcessor queue #13 is currently 81.0 percent full that is at or above 70.0 percent threshold
102022-02-09 02:56:15.465+0000 [L: WARN] [O: c.t.p.p.StreamEntryProcessor] [I: ] [U: ] [S: ] [P: ] [T: Timer-6] PersistentPropertyProcessor queue #14 is currently 82.0 percent full that is at or above 70.0 percent threshold
112022-02-09 02:56:15.465+0000 [L: WARN] [O: c.t.p.p.StreamEntryProcessor] [I: ] [U: ] [S: ] [P: ] [T: Timer-6] PersistentPropertyProcessor queue #16 is currently 79.0 percent full that is at or above 70.0 percent threshold
BatchValueStreamProcessor
platform1_1 | 2022-02-22 21:09:08.208+0000 [L: WARN] [O: c.t.p.p.StreamEntryProcessor] [I: ] [U: ] [S: ] [P: platform1] [T: Timer-9] BatchValueStreamProcessor queue #81 is currently 100.0 percent full that is at or above 70.0 percent threshold
platform1_1 | 2022-02-22 21:09:08.208+0000 [L: WARN] [O: c.t.p.p.StreamEntryProcessor] [I: ] [U: ] [S: ] [P: platform1] [T: Timer-9] BatchValueStreamProcessor queue #82 is currently 100.0 percent full that is at or above 70.0 percent threshold
platform1_1 | 2022-02-22 21:09:08.208+0000 [L: WARN] [O: c.t.p.p.StreamEntryProcessor] [I: ] [U: ] [S: ] [P: platform1] [T: Timer-9] BatchValueStreamProcessor queue #83 is currently 100.0 percent full that is at or above 70.0 percent threshold
platform1_1 | 2022-02-22 21:09:08.208+0000 [L: WARN] [O: c.t.p.p.StreamEntryProcessor] [I: ] [U: ] [S: ] [P: platform1] [T: Timer-9] BatchValueStreamProcessor queue #84 is currently 100.0 percent full that is at or above 70.0 percent threshold
platform1_1 | 2022-02-22 21:09:08.208+0000 [L: WARN] [O: c.t.p.p.StreamEntryProcessor] [I: ] [U: ] [S: ] [P: platform1] [T: Timer-9] BatchValueStreamProcessor queue #85 is currently 100.0 percent full that is at or above 70.0 percent threshold
Los registros de aplicación deben supervisarse para cada procesador de entrada de flujo para intentar minimizar el número de entradas rechazadas.
A continuación se encuentra la plantilla de esta sentencia de registro:
{ProcessorName} queue #{queue number} is curently {percentage} percent full that is at or above 70.0 percent threshold
A continuación se indican los nombres de todos los procesadores de flujo que pueden aparecer en las sentencias de registro anteriores en lugar de {ProcessorName}:
BatchStreamProcessor
BatchValueStreamProcessor
ValueStreamProcessor
DataTableProcessor
InfluxdbStreamProcessor
InfluxdbValueStreamProcessor
PersistentPropertyProcessor
StreamProcessor
¿Fue esto útil?