停止Tkinter中的tweepy流

Question

我正在尝试使用TkinterGUI使用python/tweepy来流式传输推文。理想情况下，我会有一个启动流的“开始”按钮和一个停止流的“停止”按钮。下一个示例（来自stackoverflow）以一种简化的方式展示了我试图实现的目标：

import Tkinter as tk
import threading

class App():
    def __init__(self, master):
        self.isrecording = False
        self.button1 = tk.Button(main, text='start')
        self.button2 = tk.Button(main, text='stop')

        self.button1.bind("<Button-1>", self.startrecording)
        self.button2.bind("<Button-1>", self.stoprecording)
        self.button1.pack()
        self.button2.pack()

    def startrecording(self, event):
        self.isrecording = True
        t = threading.Thread(target=self._record)
        t.start()

    def stoprecording(self, event):
        self.isrecording = False
        print "\nStopped"

    def _record(self):
        while self.isrecording:
            print "Downloading tweets"

main = tk.Tk()
app = App(main)
main.mainloop()

我试图将此应用到我的代码中，开始按钮工作正常，完成了它应该做的所有事情，但停止按钮没有做任何事情。窗口没有冻结或任何东西，只是停止按钮没有效果。由于什么事也没有发生，溪流还在继续。我在这里发布我的代码：

from Tkinter import *
import threading
import codecs
import urllib, json, tweepy,time
from datetime import datetime
from tweepy import Stream
from tweepy import OAuthHandler
from tweepy.streaming import StreamListener

consumer_key = ""
consumer_secret = ""
access_key = ""
access_secret = ""
auth = OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_key, access_secret)
keyword = "Poland"

class App():
    def __init__(self, master):
        self.isrecording = False
        self.button1 = Button(main, text='start')
        self.button2 = Button(main, text='stop')
        self.button1.bind("<Button-1>", self.startrecording)
        self.button2.bind("<Button-1>", self.stoprecording)
        self.button1.pack()
        self.button2.pack()

    def startrecording(self,event):
        self.isrecording = True
        t = threading.Thread(target=self._record)
        t.start()

    def stoprecording(self, event):
        self.isrecording = False

    def _record(self):
        while self.isrecording:
            class listener(StreamListener):
                def on_data(self,data):
                    imageFolder = "H:\Bogdan\imageFolder"
                    decoded = json.loads(data)
                    encoded = decoded['text'].encode('ascii','ignore')
                    if "http" not in encoded:
                        encodedStrip = encoded.translate(None, '@,/,\\,",<,>,:,|,?,*').replace("\n","")
                        print encodedStrip
                        if "media" in decoded['entities']:
                            for value in decoded['extended_entities']['media']:
                                imageLink = value['media_url']
                                urllib.urlretrieve(imageLink, imageFolder+"\\"+encodedStrip+"_"+str(time.time())+".jpg")
                        print 'downloading...'
                        return True

                    else:
                        encodedHTTP = encoded[:encoded.index("http")-2]
                        encodedStrip = encodedHTTP.translate(None, '@,/,\\,",<,>,:,|,?,*').replace("\n","")
                        print encodedStrip
                        if "media" in decoded['entities']:
                            for value in decoded['extended_entities']['media']:
                                imageLink = value['media_url']
                                urllib.urlretrieve(imageLink, imageFolder+"\\"+encodedStrip+"_"+str(time.time())+".jpg")
                        print 'downloading...'
                        return True
                def on_error(self,status):
                    print status

            twitterStream = Stream(auth,listener())
            twitterStream.filter( track = [keyword] )



main = Tk()
app = App(main)
main.mainloop()

你知道我要做什么改变才能让它工作吗？

非常感谢你！

Answer 1

我对tkinter了解不多，但我可以告诉你“停止”按钮不起作用的原因，因为你没有停止流。

在类侦听器（StreamListener）中：您需要指定twitterStream。断开连接（）。这将停止您与流式API之间的连接。

可以添加以下内容：

while isrecording:
    ## enter code here
else:
    ## anything that might apply

Answer 2

我猜你的代码的问题是，你在循环中初始化了一个流对象，你必须明白Stream对象本身包含一个无限循环，它不断寻找新的流推文。因此，一旦您初始化了一个Stream对象，它将自动运行，直到您手动终止进程，因此在循环时，在下初始化Stream对象是没有意义的

您需要遵循的策略是：

• 当按下开始按钮时初始化Stream对象。
• 当按下停止按钮时停止流。

通过编辑on\u data（）方法可以轻松实现此行为，您可以在on\u data（）方法中写入return True的末尾添加以下行：

if isrecording: #Initialise a variable named isrecording.
    return True
else:
    return False