本发明提供一种基于分布式的数据流处理方法和系统，通过工作节点根据从主节点接收的逻辑任务中用于指示进行指定操作的目标逻辑任务的接收速率，以及对目标逻辑任务执行指定操作的处理速率，确定指定操作对应的并行度，根据并行度，对目标逻辑任务进行整合获得物理任务，所述物理任务的数量为所述并行度，从而对物理任务并行执行指定操作，由于根据逻辑任务的接收速率和逻辑任务的处理速率，动态确定各个操作的并行度，从而解决了现有技术中由于不能适应数据流的时变性和外部负载变化所导致的系统资源的浪费或数据流处理延迟的技术问题。