起因

我在github上发起了一个开源项目:《HelloGitHub月刊》,内容是github上收集的好玩,容易上手的开源项目。

目的:因为兴趣是最好的老师,我希望月刊中的内容可以激发读者的兴趣,从而动手参与到开源的项目中,一方面提高编程技术、另一方面哪怕是能力有限不能为开源项目提交代码,也可以给个‘star’,表示对有意思、优秀的开源项目的支持!从而让开源社区越来越好。

所以,我就需要收集github上的开源项目,目前通过两种方式发现github上优秀的项目:

  1. Follow活跃的Github用户,收集他们Starred的项目
  2. Github的Explore页

然后,我就想能不能写个脚本,每天跑一次把这两个数据源的数据,收集整理好,然后发到我的邮箱中。这个需求很简单,初步感觉就两个问题:

  1. 数据源的api
  2. 发邮件的方法

过程

数据源

Github API提供了诸多获取Github数据的接口:

  1. List public events that a user has receivedGET /users/:username/received_events/public,这个接口返回user的动态(包含user关注的用户、项目的动态)
  2. 暂时没找到Explore页的接口,如果实在找不到,我就尝试爬取。

代码

完整的代码我的Github

1、请求api:

首选requests库,真的是居家旅行必备良品。需要注意一点,请求GET /users/:username/received_events/public需要用户验证,请求api的函数如下:

def get_data(page=1, per_page=100):
"""
从目标源获取数据
""" args = '?page={page}&per_page={per_page}'.format(
page=page, per_page=per_page) response = requests.get(API['events']+args,
auth=(ACCOUNT['username'], ACCOUNT['password']))
status_code = response.status_code
if status_code == 200:
resp_json = response.json()
return resp_json
else:
logging.error('请求api失败:', status_code)
return None
2、根据条件过滤数据:

请求api回来的json数据如下:

[
...
{
"id": "4123123423",
"type": "WatchEvent",
"actor": {
"id": 12342134,
"login": "gera2ld",
"display_login": "gera2ld",
"gravatar_id": "",
"url": "https://api.github.com/users/gera2ld",
"avatar_url": "https://avatars.githubusercontent.com/u/3139113?"
},
"repo": {
"id": 23412431,
"name": "yahoo/gifshot",
"url": "https://api.github.com/repos/yahoo/gifshot"
},
"payload": {
"action": "started"
},
"public": true,
"created_at": "2016-09-03T16:25:34Z",
"org": {
"id": 234234,
"login": "yahoo",
"gravatar_id": "",
"url": "https://api.github.com/orgs/yahoo",
"avatar_url": "https://avatars.githubusercontent.com/u/16574?"
}
},
{
"id": "234234",
"type": "WatchEvent",
"actor": {
"id": 21341234,
"login": "phith0n",
"display_login": "phith0n",
"gravatar_id": "",
"url": "https://api.github.com/users/phith0n",
"avatar_url": "https://avatars.githubusercontent.com/u/5711185?"
},
"repo": {
"id": 23234,
"name": "yummybian/ThreadPool",
"url": "https://api.github.com/repos/yummybian/ThreadPool"
},
"payload": {
"action": "started"
},
"public": true,
"created_at": "2016-09-03T16:12:56Z"
}
]
...

分析上面的json数据,其中可能会包含我不需要的信息(非starred事件的数据)需要过滤掉、同时需要根据时间获取某一段时间的数据。比如我写的这个github bot脚本获取24个小时的数据,我设定脚本每天凌晨4点跑——例如:9.3 4:00——9.4 4:00(24h的数据)。下面写了两个函数,用于过滤符合条件的数据:

注意: 接口返回的数据中的create_at字段的时间值形如——created_at: "2016-09-03T16:12:56Z" 是‘协调世界时’,‘Z’是协调世界时中0时区的标志,北京是8时区,所以就是需要在这个时间的基础上+8小时。这个事件发生于北京时间:"2016-09-04 00:12:56"

def check_condition(data):
"""
过滤条件
"""
create_time = datetime.datetime.strptime(
data['created_at'], "%Y-%m-%dT%H:%M:%SZ") + datetime.timedelta(hours=8)
date_condition = create_time >= (datetime.datetime.now()
- datetime.timedelta(days=DAY))
if (data['type'] == 'WatchEvent') and date_condition:
if data['payload']['action'] == 'started':
data['date_time'] = create_time.strftime("%Y-%m-%d %H:%M:%S")
return True
else:
return False def analyze(json_data):
"""
分析获取的数据
:return 符合过滤条件的数据
"""
result_data = []
for fi_data in json_data:
if check_condition(fi_data):
result_data.append(fi_data)
return result_data
3、生成发送邮件的内容:

最终邮件内容如下:

注意: 因为获取项目stars数的接口,有的时候获取数据很慢,所以设置了超时时间。最好的方法因该是以异步的方式解决。可以参考grequests项目

CONTENT_FORMAT = """
<table border="2" align="center">
<tr>
<th>头像</th>
<th>用户名</th>
<th>项目名</th>
<th>starred日期</th>
<th>项目star数量</th>
</tr>
{starred_info}
</table>
""" def make_content():
"""
生成发布邮件的内容
"""
json_data = get_data()
data = analyze(json_data)
content = [] for fi_data in data:
user = fi_data['actor']['login']
user_url = 'https://github.com/' + user
avatar_url = fi_data['actor']['avatar_url']
repo_name = fi_data['repo']['name']
repo_url = 'https://github.com/' + repo_name
date_time = fi_data['date_time']
try:
repo_stars = requests.get(fi_data['repo']['url'], timeout=2).json()
if repo_stars:
repo_stars = repo_stars['stargazers_count']
else:
repo_stars = '未知数'
except Exception as e:
repo_stars = '未知数'
logger.warning(u'获取:{} 项目星数失败——{}'.format(repo_name, e))
starred_info = """<tr>
<td><img src={avatar_url} width=32px></img></td>
<td><a href={user_url}>{user}</a></td>
<td><a href={repo_url}>{repo_name}</a></td>
<td>{date_time}</td>
<td>{repo_stars}</td>
</tr>
""".format(user=user, repo_name=repo_name,
repo_url=repo_url, user_url=user_url,
avatar_url=avatar_url, repo_stars=repo_stars,
date_time=date_time)
content.append(starred_info)
return content
4、发送邮件:

如果是使用qq邮箱发送邮件,可以参考:qq邮件服务文档

注意: 发送邮件使用的邮箱密码,最好用授权码,因为我在测试邮件发送功能时,发送邮件的次数太多,后面突然不能发送了!而且没有任何错误提示,就卡在sendmail方法!后来登录qq邮箱,发现让我使用授权码 进行第三方授权。最后使用授权码一切就ok了!

发送邮件的函数如下:

def send_email(receivers, email_content):
"""
发送邮件
"""
sender = MAIL['mail'] # 发送邮件的邮箱
receivers = receivers # 接收邮件的邮箱,可设置多个 # 三个参数:第一个为文本内容,第二个 html 设置文本格式,第三个 utf-8 设置编码
message = MIMEText(
CONTENT_FORMAT.format(starred_info=''.join(email_content)),
'html', 'utf-8'
)
message['From'] = Header(u'Github机器人', 'utf-8')
message['To'] = Header(u'削微寒', 'utf-8') subject = u'今日Github热点' # 设置邮件主题
message['Subject'] = Header(subject, 'utf-8')
try:
smtp_obj = smtplib.SMTP_SSL() # qq邮箱要求是https连接,所以需要用SMTP_SSL
smtp_obj.connect(MAIL['host'], MAIL['port']) # 设置SMTP地址和端口号
smtp_obj.login(MAIL['username'], MAIL['password'])
smtp_obj.sendmail(sender, receivers, message.as_string())
except smtplib.SMTPException as e:
logger.error(u"无法发送邮件: {}".format(e))

完整的代码我的Github

最后

参照crontab 定时任务,在linux下设置定时任务。

1. EDITOR=vi; export EDITOR #使用vi编辑器编辑

2. crontab -e #加入定时任务

3. crontab -l #查看是否加入成功

TODO

  1. 获取Explore页的数据

参考

最新文章

  1. FixFFmpeg 修改官方编译的ffmpeg能在 XP 上运行的工具
  2. JQuery选择器细节-遁地龙卷风
  3. android 入门-Service实时向Activity通过BroadcastReceiver传递数据
  4. 运行js提示库没有注册错误8002801d的解决办法
  5. XE6移动开发环境搭建之IOS篇(4):VMware9里安装Mac OSX 10.8(有图有真相)
  6. 《Python CookBook2》 第四章 Python技巧 对象拷贝 &amp;&amp; 通过列表推导构建列表
  7. ThinkPHP中SQL调试方法
  8. Android写入文件操作权限
  9. (原)ubuntu14.04中安装gcc4.9和g++4.9
  10. Install shipyard
  11. javascript call()函数
  12. 【转】关于swf安全沙箱冲突:不能被本地访问
  13. linkin大话设计模式--观察者模式
  14. IP路由及静态路由配置
  15. css公共库——简介中超过长度显示省略号
  16. python之MRO和垃圾回收机制
  17. transition,过渡效果
  18. 四两拨千斤式的攻击!如何应对Memcache服务器漏洞所带来的DDoS攻击?
  19. java压缩与解压
  20. STM32F10x_SPI(硬件接口 + 软件模拟)读写Flash(25Q16)

热门文章

  1. Python Beautiful Soup学习之HTML标签补全功能
  2. php数组常见的几种遍历方法
  3. 面试题12:打印1到最大的n位数
  4. IDEA安装配置(SVN)
  5. 锤子手机T2 屏幕录像文件保存在哪里?
  6. ios http请求
  7. 用vc生成可被python调用的dll文件
  8. etl工具
  9. win32记事本程序(二)
  10. Cocos2d-x win7 + vs2010 配置图文详解