DolphinDB已经有非常多的窗口计算函数，例如m系列的滑动窗口计算，cum系列累计窗口计算，tm系列的的时间窗口滑动计算。但是所有这类函数都是对窗口内的所有记录进行指标计算，难免包含很多噪音。DolphinDB的金融领域用户反馈，通过交易量信息等对窗口内的记录进行过滤，得到的计算指标具有更高的质量，以此为基础的交易策略能带来更多的Alpha。同时用户也反馈，通过自定义函数来计算按额外信息过滤后的指标，消耗的时间过长。为此，DolphinDB推出了TopN系列内置函数，涵盖mTopN系列、tmTopN系列、cumTopN系列，通过增量计算，大幅提升性能。DolphinDB2.00.10及1....

DolphinDB作为一款高性能时序数据库，其在实际生产环境中常有数据的清洗、装换以及加载等需求，而对于该如何结构化管理好ETL作业，Airflow提供了一种很好的思路。本篇教程为生产环境中ETL实践需求提供了一个解决方案，将PythonAirflow引入到DolphinDB的高可用集群中，通过使用Airflow所提供的功能来实现更好管理DolphinDB数据ETL作业，整体架构如下: 1.Airflow 1.1Airflow简介 Airflow是一个可编程，调度和监控的工作流平台，基于有向无环图(Directedacyclicgraph,DAG)，Airflow可以定义一组有依赖的任务，按...