新浪微博监听关注用户最新微博并转发至邮箱(含图)

跑跑慢慢

关注了一些账户,不过经常遇见发布没多久就删除的,所以尝试写了该工具.经过逐步完善,现在已经可以发布带图片的邮件内容,不过图片只有一张,有时间稍微加一些代码就可更新.

准备工作:
新浪微博开发平台SDK python版: https://github.com/michaelliao/sinaweibopy/zipball/master
自己在开发平台创建一个自己的应用: 我的应用类型:普通应用  -  客户端.
邮件中图片是先下载到本地e:/weibo/中,再发送到邮件.
另外注意:mailimages.py 中,请将#换行# 替换为html中的换行标签<br>
代码:auth.py
更新get_code()方法,使用code = get_code(authorize_url),不需要手动输入code值. 缩进貌似有问题,自己解决.

1. def get_code(url):
   
2.     conn = httplib.HTTPSConnection('api.weibo.com')
   
3.     postdata = urllib.urlencode({'client_id':APP_KEY,'response_type':'code','redirect_uri':REDIRECT_URL,'action':'submit','userId':ACCOUNT,'passwd':PASSWORD,'isLoginSina':0,'from':'','regCallback':'','state':'','ticket':'','withOfficalFlag':0})
   
4.     conn.request('POST','/oauth2/authorize',postdata,{'Referer':url,'Content-Type': 'application/x-www-form-urlencoded'})
   
5.     res = conn.getresponse()
   
6.     location = res.getheader('location')
   
7.     code = location.split('=')[1]
   
8.     conn.close()
   
9.     return code

复制代码

1. #!/usr/bin/env python
   
2. #-*- coding:utf-8 -*-
   
3. import weibo
   
4. import webbrowser
   
5. import json
   
6. import os
   
7. import sys
   
8. import time
   
9. """
   
10. 获取授权信息
    
11. 接口:
    
12. statuses/user_timeline
    
13. 调用方式:
    
14. client.statuses.user_timeline.get(uid=自己的uid)
    
15. """
    
16. APP_KEY = '1111111111'#填写自己的app_key
    
17. APP_SECRET ='aaaaaaaaaaaaaaaaaaaa'#填写自己的app_secret
    
18. REDIRECT_URL = 'https://api.weibo.com/oauth2/default.html'#应用地址
    
19. 
    
20. def getClient():
    
21.     client = weibo.APIClient(APP_KEY,APP_SECRET)
    
22.     authorize_url = client.get_authorize_url(REDIRECT_URL)
    
23. 
    
24.     webbrowser.open(authorize_url)
    
25. 
    
26.     code = raw_input('input the code: ').strip()
    
27. 
    
28.     request = client.request_access_token(code,REDIRECT_URL)
    
29. 
    
30.     access_token = request.access_token
    
31.     expires_in = request.expires_in
    
32.     uid = request.uid
    
33. 
    
34.     client.set_access_token(access_token,expires_in)
    
35.     return client

复制代码

代码2:listen.py

1. #!/usr/bin/env python
   
2. #-*- coding:utf-8 -*-
   
3. 
   
4. import weibo
   
5. import json
   
6. import os
   
7. import sys
   
8. import time
   
9. import mailimages
   
10. import urllib
    
11. """
    
12. 获取uid 最新发表的微博列表(只能是自己的uid:微博id)
    
13. 接口:
    
14. statuses/user_timeline
    
15. 调用方式:
    
16. client.statuses.user_timeline.get(uid=自己的uid)
    
17. """
    
18. uid='**********'#更换自己的uid
    
19. def eachCall(server,client,maxId):
    
20.     """
    
21.     获取自己关注列表发布的微博信息
    
22.     """
    
23.     if maxId==0:
    
24.         callback = client.statuses.friends_timeline.get(count=100)#每次运行,第一次获得100条微博记录.100为最大值
    
25.     else:
    
26.         callback = client.statuses.friends_timeline.get(count=10)#之后每次获得10条记录,可随意修改,100为最大值
    
27.     newMaxId = callback.statuses[0].id
    
28.     file = open('e:/weibo/weibo2.txt','a')#保存至本地文件中,可以去掉.
    
29.     for status in callback.statuses:
    
30.         id = status.id
    
31.         if id<=maxId:
    
32.             break;
    
33.         create_at = status.created_at
    
34.         user = status.user.name
    
35.         text = status.text
    
36.         pic_urls = status.pic_urls
    
37.         if 'retweeted_status' in status.keys():
    
38.             retweeted_status = status.retweeted_status
    
39.             retweeted_info = getNameText(retweeted_status,id)
    
40.             mailContent = text+'['+retweeted_info[0]+':'+retweeted_info[1]+']'
    
41.         else:
    
42.             mailContent = text
    
43.         #"""
    
44.         images=[]
    
45.         if 'original_pic' in status.keys():
    
46.             pic = status.original_pic
    
47.             print(pic)
    
48.             type=os.path.splitext(pic)[1][1:]
    
49.             urllib.urlretrieve(pic,'e:/weibo/%s.%s' % (str(id),type))
    
50.             images.append('e:/weibo/%s.%s' % (str(id),type))
    
51.         #"""
    
52.         content = user+"\t"+create_at+"\n\t"+mailContent+"\n"
    
53.         print(content)
    
54.         file.write(content.encode('utf-8'))
    
55.         file.flush()
    
56.         mailimages.sendmail(server,user,mailContent,images)
    
57.     file.close()
    
58.     return newMaxId
    
59. def run(client,maxId=0):
    
60.     server = mailimages.login()
    
61.     maxId = eachCall(server,client,maxId)
    
62.     time.sleep(60)
    
63.     while True:
    
64.         maxId = eachCall(server,client,maxId)
    
65.         print(maxId)
    
66.         time.sleep(60)#每60秒获取一次最新微博
    
67. def getNameText(status,id):
    
68.     """
    
69. 获取[name,text]
    
70.     """
    
71.     result = []
    
72.     if 'user' in status.keys():
    
73.         result.append(status.user.name)
    
74.         result.append(status.text)
    
75.     else:
    
76.         result.append('')
    
77.         result.append('')
    
78.     #"""
    
79.     if 'original_pic' in status.keys():
    
80.         pic = status.original_pic
    
81.         extension=os.path.splitext(pic)[1][1:]
    
82.         path = 'e:/weibo/%s.%s' % (str(id),extension)
    
83.         print(path)
    
84.         urllib.urlretrieve(pic,path)
    
85.         result.append(pic)
    
86.     else:
    
87.         result.append('')
    
88.     #"""
    
89.     return result
    
90.         
    

复制代码

代码3:mailimages.py 用于发送邮件.请将#换行# 替换为html中的换行标签<br>

1. #!/usr/bin/env python
   
2. #-*-coding:utf-8 -*-
   
3. import smtplib,mimetypes
   
4. import time
   
5. import os
   
6. 
   
7. from email.MIMEMultipart import MIMEMultipart
   
8. from email.MIMEText import MIMEText
   
9. from email.MIMEImage import MIMEImage
   
10. 
    
11. fromAddress = '***@***'
    
12. toAddress = '***@qq.com'
    
13. mail_host = 'smtp.exmail.qq.com'
    
14. mail_user = '***@***'
    
15. mail_pass = '******'
    
16. 
    
17. def sendmail(server,nick,content,images=[]):
    
18.     """
    
19.     send a email with 微博内容
    
20.     """
    
21.     # Create the root message and fill in the from, to, and subject headers
    
22.     msgRoot = MIMEMultipart('related')
    
23.     msgRoot['From'] = "微博"
    
24.     msgRoot['To'] = '******@qq.com'
    
25.     msgRoot['Subject'] = nick #以用户昵称为标题
    
26. #msgRoot.preamble = 'This is a multi-part message in MIME format.'
    
27.    
    
28.     # Encapsulate the plain and HTML versions of the message body in an
    
29.     # 'alternative' part, so message agents can decide which they want to display.
    
30.     msgAlternative = MIMEMultipart('alternative')
    
31.     msgRoot.attach(msgAlternative)
    
32. 
    
33.     msgText = MIMEText('This is the alternative plain text message.')
    
34.     msgAlternative.attach(msgText)
    
35. 
    
36.     # We reference the image in the IMG SRC attribute by the ID we give it below
    
37. 
    
38.     msgImages=[]
    
39.     if len(images)>0:
    
40.         i=0
    
41.         for image in images:
    
42.             # This example assumes the image is in the current directory
    
43.             fp = open(image, 'rb')
    
44.             msgImage = MIMEImage(fp.read())
    
45.             fp.close()
    
46.             
    
47.             # Define the image's ID as referenced above
    
48.             msgImage.add_header('Content-ID', '<image'+str(i)+'>')
    
49.             msgImages.append(msgImage)
    
50.             
    
51.             content+='#换行#<img src="cid:image'+str(i)+'">'#请将#换行# 替换为html中的换行标签.
    
52.             i+=1
    
53. 
    
54.     msgText = MIMEText(content,'html',_charset='utf-8')
    
55.     msgAlternative.attach(msgText)
    
56.     if len(msgImages)>0:
    
57.         for msgImage in msgImages:
    
58.             msgRoot.attach(msgImage)
    
59.             
    
60.     try:
    
61.         server.sendmail(fromAddress,toAddress,msgRoot.as_string())
    
62.         #print('Successfully')
    
63.     except Exception , e:
    
64.         print('=======Try to login on mail server again=======')
    
65.         server = login()
    
66.         try:
    
67.             server.sendmail(fromAddress,toAddress,msgRoot.as_string())
    
68.             print('Successfully')
    
69.         except Exception , e:
    
70.             print str(e)
    
71. def flood():
    
72.     while True:
    
73.         sendmail()
    
74.         time.sleep(30)
    
75. 
    
76. def login():
    
77.     try:
    
78.         server = smtplib.SMTP()
    
79.         server.connect(mail_host)
    
80.         server.login(mail_user,mail_pass)
    
81.         return server
    
82.     except Exception , e:
    
83.         print str(e)
    
84. def logout(server):
    
85.     try:
    
86.         server.close()
    
87.     except Exception , e:
    
88.         print str(e)
    

复制代码

运行方式:
>>> import auth,listen
>>> c=auth.getClient()
input the code:
此时浏览器打开页面,登录自己的微博账户,浏览器跳转到一个地址,后面为code=******.
把=后面的数值输入
>>> listen.run(c)

每次监听后都会打印一个id值.
如果运行中断,可以加上id参数,从上次监听处继续监听.
>>> listen.run(c,id值)

-------------结束.

simple

牛B 。。顶上去