您可以从不同的Angular 来看待这个问题，以简化解决方案，对于每3次连续的购买，检查其中一次是否在5天的范围内，并且在按“Date O Purchase”（购买日期）排序数据后进一步简化，您只需要按该顺序检查当前行和当前行（这意味着最近3次购买）并检查这2行的日期是否在5天内，这里是PySpark中的解决方案：

w = Window.partitionBy("Cust_Id").orderBy("Date_Of_Purchase")
df = df.withColumn("Date_Of_Purchase", to_date(col("Date_Of_Purchase"), "dd/MM/yyyy")) \
    .withColumn("Prev_Date_Of_Purchase", lag("Date_Of_Purchase", 2).over(w)) \
    .withColumn("days_between", datediff(col("Date_Of_Purchase"), col("Prev_Date_Of_Purchase")))
df.show()

df.filter(col("days_between") <= 5).select("Cust_Id").distinct().show()

字符串

编辑：

您可以通过将lag("Date_Of_Purchase", 2)中的2更改为购买次数-1，并将.filter(col("days_between") <= 5)中的5更改为天数间隔窗口来概括这一点。