如何在x秒后停止/关闭Twitter API过滤流？

Question

我只是想知道如何在x秒后停止Twitter过滤的蒸汽。

到目前为止，我已经知道了这一点：

t_end = time.time() + 10

while time.time() < t_end:
    bearer_token = config.BEARER_TOKEN
    headers = create_headers(bearer_token)
    rules = get_rules(headers, bearer_token)
    delete = delete_all_rules(headers, bearer_token, rules)
    set = set_rules(headers, delete, bearer_token)
    get_stream(headers, set, bearer_token)
print("ended")

然而，这条溪流仍在继续。我似乎无法在Twitter文档中找到如何关闭流或关闭流的方法。

Answer 1

流式传输的意思是在一个连续的流中传输和接收数据。但是，在python中，您可以使用库来阻止它。

一种方法是使用穿线，在流中开始计算时间，并在一段时间后中止python文件：

# after building your arguments like bearer token and rules

def manage_streaming():
    thread1 = threading.Thread(target=get_stream, args=(headers, set, bearer_token,))
    thread1.start()
    sleep(time_2_end_in_seconds)
    print('ended')
    break  # or you can use sys.exit() directly here to stop the 
           # executing file.