Как я могу создать поток данных из кадра данных pandas? - PullRequest
0 голосов
/ 10 ноября 2019

Я ищу способ создания потока данных из статических данных, например. Я хочу создать источник, куда каждая строка данных будет поступать через 10 мс. Есть ли способ сделать это?

1 Ответ

0 голосов
/ 10 ноября 2019

Вы можете просто выполнить итерацию с таймером ожидания, используя yield для создания генератора, я использовал itertuples, но вы можете изменить способ итерации данных

import time
import pandas as pd

def yield_wait(frame, ms):
    for v in frame.itertuples():
        yield v
        time.sleep(ms / 1000)

if __name__ == '__main__':
    inp = [{'c1': 10, 'c2': 100}, {'c1': 11, 'c2': 110}, {'c1': 12, 'c2': 120}]
    df = pd.DataFrame(inp)

    for v in yield_wait(df, 1000): # print every 1sec
        print(v)
...