本申请实施例提供了一种分布式流水线的数据处理方法、装置、电子设备及存储介质，涉及数据库技术领域，适用于MPP数据库中跨节点多任务交换数据场景。该方法包括创建异步执行的数据处理线程以及数据传输线程；通过数据传输线程获得上游任务生成的压缩后数据；通过数据处理线程对上游任务的压缩后数据解压缩并执行当前任务，确定并根据当前的目标压缩算法对当前任务生成的数据进行压缩，将当前任务生成的压缩后数据存放至发送缓冲区；通过数据传输线程向相应的下游任务发送发送缓冲区中的数据。本申请实施例能够充分利用节点的算力并实现生产数据和发送数据的动态平衡，提高整条流水线的吞吐量和资源利用率，减少查询执行耗时。