Is it possible to use event time/syntethic time rather than system time?

オープン

#465 2023年1月16日に作成コメント 2 件リアクション 0 件担当者 0 名 GitHub で見る

まだ誰も着手していません。

評価

難易度: 5/5
見積もり時間: 1週間以上
初心者へのやさしさ: 30/100

issue の種類: 機能追加
明瞭さ: 説明が足りない
活発さ: 停滞
技術スタック: python
領域: stream-processing

調査の方向性

Start by reviewing the implementations of timed_window, delay, and rate_limit, focusing on their use of time(). Determine how an event timestamp such as event['timestamp'] could be supplied for offline historical processing, and define the expected behavior before implementation. Done should include a clear supported approach for synthetic or event time.

索引モデルが issue の本文から書いたものです。

説明

I want to use streamz for offline processing on historical data, the data is timestamped. Looking through source code, time related streams (e.g. timed_window, delay, rate_limit, etc.) use time() function for event time. Is it possible to fetch existing value (i.e. event['timestamp']) to these streams so I can do offline processing? If not, what would be the best way to go about this?

主要言語: Python
スター: 1.3k
フォーク: 149
平均マージ: 17時間 39分
マージ済み PR（30日）: 1

コントリビューションガイド

コントリビューションガイドを開く

はじめの一歩

issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
リポジトリをフォークし、ブランチを切って変更します。
issue 番号を参照したプルリクエストを送ります。

python-streamz/streamz のほかの issue

pkg_resources warning オープン

難易度 3/5 1〜2日初心者へのやさしさ 35/100

python-streamz/streamz#481 · コメント 4 件 · 2025年6月23日に作成
Combining the streamz.Stream.filenames() and streamz.Stream.from_textfile() using dask scatter? オープン

難易度 5/5 1週間以上初心者へのやさしさ 25/100

python-streamz/streamz#480 · コメント 2 件 · 2025年2月10日に作成
Compile the code into c++ オープン

難易度 5/5 1週間以上初心者へのやさしさ 20/100

python-streamz/streamz#479 · コメント 1 件 · 2024年10月28日に作成
Suggestions for improving code performance オープン

難易度 5/5 1週間以上初心者へのやさしさ 20/100

python-streamz/streamz#478 · コメント 6 件 · 2024年9月17日に作成
Is streamz not maintained anymore? What happened to cuStreamz? オープン

難易度 4/5 3〜5日初心者へのやさしさ 10/100

python-streamz/streamz#476 · コメント 17 件 · リアクション 2 件 · 2024年4月28日に作成

python-streamz/streamz の issue をすべて見る

似ている issue

validate-structure inspecte challenge/work/.terraform et rend faux les labs qui ont un provider en cache オープン

bug

難易度 2/5 1〜3時間初心者へのやさしさ 75/100

stephrobert/dsoxlab#238 · 2026年9月24日に作成
Uniform probability densities use the upper bound as an interval width オープン

難易度 2/5 1〜3時間初心者へのやさしさ 75/100

nasa/fmdtools#40 · 2026年9月24日に作成
_common_folder() treats a single file as the common folder; single-file archives can't be installed (4.2.8) / crash (master) オープン

難易度 2/5 1〜3時間初心者へのやさしさ 75/100

sublimehq/package_control#1780 · 2026年9月24日に作成
Set 'Sample' input in 'autorun.py' to utilize 'Sample' Tab in eLog オープン

難易度 2/5 1〜3時間初心者へのやさしさ 65/100

pcdshub/mfx#309 · コメント 2 件 · 2026年9月24日に作成
niri config file addition does not respect existing optional include オープン

難易度 2/5 1〜3時間初心者へのやさしさ 70/100

nwg-piotr/nwg-displays#145 · 2026年9月24日に作成

Python の issue をもっと見る