新浪微博监听关注用户最新微博并转发至邮箱(含图) - Crossin的编程教室

def get_code(url):
conn = httplib.HTTPSConnection('api.weibo.com')
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})
conn.request('POST','/oauth2/authorize',postdata,{'Referer':url,'Content-Type': 'application/x-www-form-urlencoded'})
res = conn.getresponse()
location = res.getheader('location')
code = location.split('=')[1]
conn.close()
return code

复制代码

#!/usr/bin/env python
#-*- coding:utf-8 -*-
import weibo
import webbrowser
import json
import os
import sys
import time
"""
获取授权信息
接口:
statuses/user_timeline
调用方式:
client.statuses.user_timeline.get(uid=自己的uid)
"""
APP_KEY = '1111111111'#填写自己的app_key
APP_SECRET ='aaaaaaaaaaaaaaaaaaaa'#填写自己的app_secret
REDIRECT_URL = 'https://api.weibo.com/oauth2/default.html'#应用地址
def getClient():
client = weibo.APIClient(APP_KEY,APP_SECRET)
authorize_url = client.get_authorize_url(REDIRECT_URL)
webbrowser.open(authorize_url)
code = raw_input('input the code: ').strip()
request = client.request_access_token(code,REDIRECT_URL)
access_token = request.access_token
expires_in = request.expires_in
uid = request.uid
client.set_access_token(access_token,expires_in)
return client

复制代码

#!/usr/bin/env python
#-*- coding:utf-8 -*-
import weibo
import json
import os
import sys
import time
import mailimages
import urllib
"""
获取uid 最新发表的微博列表(只能是自己的uid:微博id)
接口:
statuses/user_timeline
调用方式:
client.statuses.user_timeline.get(uid=自己的uid)
"""
uid='**********'#更换自己的uid
def eachCall(server,client,maxId):
"""
获取自己关注列表发布的微博信息
"""
if maxId==0:
callback = client.statuses.friends_timeline.get(count=100)#每次运行,第一次获得100条微博记录.100为最大值
else:
callback = client.statuses.friends_timeline.get(count=10)#之后每次获得10条记录,可随意修改,100为最大值
newMaxId = callback.statuses[0].id
file = open('e:/weibo/weibo2.txt','a')#保存至本地文件中,可以去掉.
for status in callback.statuses:
id = status.id
if id<=maxId:
break;
create_at = status.created_at
user = status.user.name
text = status.text
pic_urls = status.pic_urls
if 'retweeted_status' in status.keys():
retweeted_status = status.retweeted_status
retweeted_info = getNameText(retweeted_status,id)
mailContent = text+'['+retweeted_info[0]+':'+retweeted_info[1]+']'
else:
mailContent = text
#"""
images=[]
if 'original_pic' in status.keys():
pic = status.original_pic
print(pic)
type=os.path.splitext(pic)[1][1:]
urllib.urlretrieve(pic,'e:/weibo/%s.%s' % (str(id),type))
images.append('e:/weibo/%s.%s' % (str(id),type))
#"""
content = user+"\t"+create_at+"\n\t"+mailContent+"\n"
print(content)
file.write(content.encode('utf-8'))
file.flush()
mailimages.sendmail(server,user,mailContent,images)
file.close()
return newMaxId
def run(client,maxId=0):
server = mailimages.login()
maxId = eachCall(server,client,maxId)
time.sleep(60)
while True:
maxId = eachCall(server,client,maxId)
print(maxId)
time.sleep(60)#每60秒获取一次最新微博
def getNameText(status,id):
"""
获取[name,text]
"""
result = []
if 'user' in status.keys():
result.append(status.user.name)
result.append(status.text)
else:
result.append('')
result.append('')
#"""
if 'original_pic' in status.keys():
pic = status.original_pic
extension=os.path.splitext(pic)[1][1:]
path = 'e:/weibo/%s.%s' % (str(id),extension)
print(path)
urllib.urlretrieve(pic,path)
result.append(pic)
else:
result.append('')
#"""
return result

复制代码

#!/usr/bin/env python
#-*-coding:utf-8 -*-
import smtplib,mimetypes
import time
import os
from email.MIMEMultipart import MIMEMultipart
from email.MIMEText import MIMEText
from email.MIMEImage import MIMEImage
fromAddress = '***@***'
toAddress = '***@qq.com'
mail_host = 'smtp.exmail.qq.com'
mail_user = '***@***'
mail_pass = '******'
def sendmail(server,nick,content,images=[]):
"""
send a email with 微博内容
"""
# Create the root message and fill in the from, to, and subject headers
msgRoot = MIMEMultipart('related')
msgRoot['From'] = "微博"
msgRoot['To'] = '******@qq.com'
msgRoot['Subject'] = nick #以用户昵称为标题
#msgRoot.preamble = 'This is a multi-part message in MIME format.'
# Encapsulate the plain and HTML versions of the message body in an
# 'alternative' part, so message agents can decide which they want to display.
msgAlternative = MIMEMultipart('alternative')
msgRoot.attach(msgAlternative)
msgText = MIMEText('This is the alternative plain text message.')
msgAlternative.attach(msgText)
# We reference the image in the IMG SRC attribute by the ID we give it below
msgImages=[]
if len(images)>0:
i=0
for image in images:
# This example assumes the image is in the current directory
fp = open(image, 'rb')
msgImage = MIMEImage(fp.read())
fp.close()
# Define the image's ID as referenced above
msgImage.add_header('Content-ID', '<image'+str(i)+'>')
msgImages.append(msgImage)
content+='#换行#<img src="cid:image'+str(i)+'">'#请将#换行# 替换为html中的换行标签.
i+=1
msgText = MIMEText(content,'html',_charset='utf-8')
msgAlternative.attach(msgText)
if len(msgImages)>0:
for msgImage in msgImages:
msgRoot.attach(msgImage)
try:
server.sendmail(fromAddress,toAddress,msgRoot.as_string())
#print('Successfully')
except Exception , e:
print('=======Try to login on mail server again=======')
server = login()
try:
server.sendmail(fromAddress,toAddress,msgRoot.as_string())
print('Successfully')
except Exception , e:
print str(e)
def flood():
while True:
sendmail()
time.sleep(30)
def login():
try:
server = smtplib.SMTP()
server.connect(mail_host)
server.login(mail_user,mail_pass)
return server
except Exception , e:
print str(e)
def logout(server):
try:
server.close()
except Exception , e:
print str(e)

复制代码