推特直接消息流

Question

我正在使用以下代码流式传输我的Twitter帐户收到的直接消息-：

from tweepy import Stream
from tweepy import OAuthHandler
from tweepy import API
from tweepy.streaming import StreamListener
# These values are appropriately filled in the code
consumer_key = ""
consumer_secret = ""
access_token = ""
access_token_secret = ""
class StdOutListener( StreamListener ):
    def __init__( self ):
        self.tweetCount = 0
    def on_connect( self ):
        print("Connection established!!")
    def on_disconnect( self, notice ):
        print("Connection lost!! : ", notice)
    def on_data( self, status ):
        print("Entered on_data()")
        print(status, flush = True)
        return True
    def on_direct_message( self, status ):
        print("Entered on_direct_message()")
        try:
            print(status, flush = True)
            return True
        except BaseException as e:
            print("Failed on_direct_message()", str(e))
    def on_error( self, status ):
        print(status)
def main():
    try:
        auth = OAuthHandler(consumer_key, consumer_secret)
        auth.secure = True
        auth.set_access_token(access_token, access_token_secret)
        api = API(auth)
        # If the authentication was successful, you should
        # see the name of the account print out
        print(api.me().name)
        stream = Stream(auth, StdOutListener())
        stream.userstream()
    except BaseException as e:
        print("Error in main()", e)
if __name__ == '__main__':
    main()

我可以打印我的名字以及"建立连接！"消息
但每当我从朋友的个人资料直接向自己的个人资料发送消息时，都不会调用任何方法
不过，每当我从个人资料中发推特时，程序都会正确打印。

我和我的朋友都在推特上互相关注，所以直接消息权限应该不会有任何问题。

做这件事的正确方法是什么？

此外，如果它根本无法在Tweepy中完成，我准备使用任何其他Python库。

我在Windows7上使用的是Tweepy 3.3.0和Python 3.4。

Answer 1

问题中提供的代码确实是正确的
问题是，在将我的应用程序权限更改为"读、写和直接消息"后，我忘记了重新生成访问令牌和密钥。

注意：直接消息以on_data()方法到达，而不是以on_direct_message()方法到达。

Answer 2

另一个解决方案是不覆盖on_data方法。这就是我如何让您的代码示例在我的案例中发挥作用。

tweetpy.streaming.StreamListener对象的on_data方法包含您和我所期望的所有json数据处理和其他方法的调用，如on_direct_message。

Answer 3

以下是2017 中代码的工作版本

    from twitter import *
import os
import  oauth
#Create a new Twitter app first: https://apps.twitter.com/app/new

APP_KEY,APP_SECRET = 'H3kQtN5PQgRiA0ocRCCjqjt2P', '51UaJFdEally81B7ZXjGHkDoDKTYy430yd1Cb0St5Hb1BVcDfE'
# OAUTH_TOKEN, OAUTH_TOKEN_SECRET = '149655407-TyUPMYjQ8VyLNY5p7jq0aMy8PjtFtd7zkIpDh3ZA', 'IUVpiDpoVmdO75UaHOTinAv5TOsAQmddttNENh9ofYuWO'

MY_TWITTER_CREDS = os.path.expanduser('my_app_credentials')
if not os.path.exists(MY_TWITTER_CREDS):
    oauth_dance("crypto sentiments", APP_KEY, APP_SECRET,
                MY_TWITTER_CREDS)
oauth_token, oauth_secret = read_token_file(MY_TWITTER_CREDS)
auth = OAuth(
    consumer_key=APP_KEY,
    consumer_secret=APP_SECRET,
    token=oauth_token,
    token_secret=oauth_secret
)
twitter_userstream = TwitterStream(auth=auth, domain='userstream.twitter.com')
for msg in twitter_userstream.user():
    if 'direct_message' in msg:
        print (msg['direct_message']['text'])