我有一个influencer对象,它有很多20K+追随者。
我可以一个接一个地读取多达45个有影响力的人,并在它的追随者上执行一个工人。它不是立即发生的,而是在几个小时后发生的。
代码:
while True:
with ThreadPoolExecutor(max_workers=45) as executor:
influencers = Influencer.objects.filter(
status__in=[ProcessStatus.recorded, ProcessStatus.unfinished, ProcessStatus