csp 0.0.5

csp 是一个高性能的反应式流处理库。其主要引擎是一个 C++ 复杂事件图处理器，并通过 Python 绑定暴露出来。其主要特性包括可切换的模拟/实时时间步长，适用于离线和在线处理，以及自定义输入和输出适配器，用于与静态和流数据源和接收器集成，并通过可定制的 C++ 节点进行可扩展加速，以进行计算。

csp 的高层目标是使编写实时代码变得简单且高效。一次编写事件驱动代码，然后在模拟中进行测试，然后作为实时代码部署而无需任何代码更改。

以下是一个简单的 csp 程序示例，用于计算 买卖价差。在这个例子中，我们使用的是固定的买卖价，但在现实世界中，您可以直接将这些值输入到您的实时流数据源或历史数据源中，而无需修改您的核心逻辑。

import csp
from csp import ts
from datetime import datetime


@csp.node
def spread(bid: ts[float], ask: ts[float]) -> ts[float]:
    if csp.valid(bid, ask):
        return ask - bid


@csp.graph
def my_graph():
    bid = csp.const(1.0)
    ask = csp.const(2.0)
    s = spread(bid, ask)

    csp.print('spread', s)
    csp.print('bid', bid)
    csp.print('ask', ask)


if __name__ == '__main__':
    csp.run(my_graph, starttime=datetime.utcnow())

运行此程序，我们的输出应如下所示（由于当前时间可能略有变化）

2024-02-07 04:37:13.446548 bid:1.0
2024-02-07 04:37:13.446548 ask:2.0
2024-02-07 04:37:13.446548 spread:1.0

入门指南

查看我们的维基百科！

开发

请参阅贡献指南和本地开发说明。

作者

csp 由 Point72 的高频算法团队开发，并得到了公司内部用户的贡献。

许可

本软件根据 Apache 2.0 许可证授权。有关详细信息，请参阅LICENSE 文件。