(v).encode('utf-8'))# 向Kafka发送数据while True: stock_data = generate_stock_data() producer.send('stock-data Sourcekafka_source = KafkaSource.builder() \ .set_bootstrap_servers('localhost:9092') \ .set_topic('stock-data
snowball2dev/stock-trade-strategy maven工程结构 stock-back-test 策略回测模块,暂未实现 stock-base 基础模块,主要是通用工具类 stock-data
具体可以参阅 stock.py (https://github.com/kamidox/stock-data/blob/master/stock.py)里的 minutes_to_days_batch 最最后,感兴趣的可以看一下 stock.ipynb ( https://github.com/kamidox/stock-data/blob/master/stock.ipynb ),这个是本文在 ipython