Python Faust Hoping Fenstertisch ⇐ Python

[Anonymous]

Ich bin neu in Faust und möchte verfolgen, wie viele Nachrichten ich in den letzten n Sekunden erhalten habe, und diese jeweils l -Sekunden aktualisieren. Ich dachte, die Hopping -Tabelle wäre für diesen Zweck geeignet.hopping_table = app.Table("hopping_table", default = int)\
.hopping(5, 1)

@app.agent(topic)
async def process(stream):
async for value in stream:
hopping_table["sum"] += 1
print(f"sum: {hopping_table['sum'].value()}")
< /code>
Aber als Ergebnis erhalte ich: < /p>
[2024-02-04 22:50:55,092] [20956] [WARNING] sum: 1
[2024-02-04 22:50:56,094] [20956] [WARNING] sum: 1
[2024-02-04 22:50:57,096] [20956] [WARNING] sum: 1
[2024-02-04 22:50:58,098] [20956] [WARNING] sum: 1
[2024-02-04 22:50:59,099] [20956] [WARNING] sum: 1
[2024-02-04 22:51:00,101] [20956] [WARNING] sum: 1
< /code>
Kann ich wollen, dass ich mit Hoping -Fenstern wollen oder ist mein Verständnis im Allgemeinen falsch? Leider habe ich nicht zu viel spezifische Informationen über Fausts Schiebern gefunden.
Danke im Voraus