Blame view
runmain.py
4.59 KB
fa7135c35
|
1 2 3 4 5 |
#!/usr/bin/env python # -*- coding: utf-8 -*- from insight.context import Context from insight.token import Token |
40c655346
|
6 |
from insight.postinsight import PostInsight |
c9e21b9c5
|
7 |
from insight.datadb import DataDB |
cd3f2b98c
|
8 9 |
from insight.url import Url |
fa7135c35
|
10 11 12 13 |
import time if __name__=='__main__': |
8576f5a77
|
14 |
token = Token() |
fa7135c35
|
15 |
|
c9e21b9c5
|
16 |
contexts = Context(token) |
7f1ef3a46
|
17 |
contexts.setContextsFeedAndTimestemp(3600 * 24 * 10) |
40c655346
|
18 |
contents_list = contexts.getContentsList() |
fa7135c35
|
19 |
|
c9e21b9c5
|
20 |
for content in contents_list: |
4af77bd17
|
21 22 |
datadb = DataDB() time.sleep(1) |
ae1adcd6e
|
23 24 |
p_id = str(content['id'].split('_')[0]) c_id = str(content['id'].split('_')[1]) |
2e4d69eb8
|
25 |
|
40c655346
|
26 |
insight = PostInsight(token) |
fa7135c35
|
27 |
insight.setContentInsight(content['id']) |
cfdd3d396
|
28 |
|
2f9e1282a
|
29 30 31 |
created_time = insight.getContentCreated_time() message = insight.getContentMessage() message_url = Url().getText2bitly(message) |
66b00f133
|
32 |
lists =["post_story_adds_unique", |
c9e21b9c5
|
33 34 35 36 37 |
"post_story_adds", "post_story_adds_by_action_type_unique,comment", "post_story_adds_by_action_type_unique,like", "post_story_adds_by_action_type_unique,share", "post_story_adds_by_action_type,comment", |
c9e21b9c5
|
38 39 40 |
"post_impressions", "post_impressions_paid_unique", "post_impressions_paid", |
2e4d69eb8
|
41 42 43 |
"post_story_adds_by_action_type,like", "post_story_adds_by_action_type,share", "post_impressions_unique", |
c9e21b9c5
|
44 45 |
"post_impressions_organic_unique", "post_impressions_organic", |
c9e21b9c5
|
46 47 |
"post_impressions_by_story_type_unique,other", "post_impressions_by_story_type,other", |
c9e21b9c5
|
48 49 50 51 52 53 54 55 |
"post_consumptions_by_type_unique,other clicks", "post_consumptions_by_type_unique,photo view", "post_consumptions_by_type_unique,video play", "post_consumptions_by_type_unique,link clicks", "post_consumptions_by_type,other clicks", "post_consumptions_by_type,photo view", "post_consumptions_by_type,video play", "post_consumptions_by_type,link clicks", |
c9e21b9c5
|
56 |
"post_engaged_users", |
86365c78e
|
57 58 59 |
"post_video_views", "post_video_views_unique", "post_video_views_paid", |
66b00f133
|
60 |
"post_video_views_autoplayed", |
c9e21b9c5
|
61 62 63 64 65 66 67 68 69 70 |
"post_video_views_10s", "post_video_views_10s_unique", "post_video_views_10s_paid", "post_video_views_10s_organic", "post_video_views_10s_clicked_to_play", "post_video_views_10s_autoplayed", "post_video_views_10s_sound_on", "post_video_views_sound_on", "post_video_view_time", "post_video_complete_views_organic", |
86365c78e
|
71 |
"post_video_complete_views_paid"] |
c9e21b9c5
|
72 |
|
66b00f133
|
73 |
sqlprefix = "insert into facebook_insights2 (" |
a4040d54a
|
74 |
sqlreplace = "REPLACE into facebook_insights2_last (" |
c9e21b9c5
|
75 |
sqlvalues = " values (" |
66b00f133
|
76 |
|
ae1adcd6e
|
77 78 |
sqlprefix += "`p_id`, " sqlprefix += "`c_id`, " |
c99dc50c3
|
79 |
sqlprefix += "`type`, " |
66b00f133
|
80 |
sqlprefix += "`message`, " |
2e4d69eb8
|
81 82 |
sqlprefix += "`message_url`, " sqlprefix += "`comment_url`, " |
66b00f133
|
83 84 |
sqlprefix += "`created_time`, " sqlprefix += "`loging_time`, " |
cfdd3d396
|
85 86 87 88 |
sqlprefix += "`bit_url`, " sqlprefix += "`bit_click`, " sqlprefix += "`origin_url`, " sqlprefix += "`piki_cid`, " |
9a4ce3987
|
89 |
sqlprefix += "`rpiki_click`, " |
cfdd3d396
|
90 |
|
ae1adcd6e
|
91 92 |
sqlvalues += p_id + ", " sqlvalues += c_id + ", " |
c99dc50c3
|
93 |
sqlvalues += "'" + insight.getContentType() + "', " |
66b00f133
|
94 |
sqlvalues += "'" + message + "', " |
2e4d69eb8
|
95 |
sqlvalues += "'" + message_url + "', " |
cfdd3d396
|
96 |
sqlvalues += "'" + insight.getContentCommentUrl() + "', " |
66b00f133
|
97 98 |
sqlvalues += "'" + created_time + "', " sqlvalues += "NOW(), " |
cd3f2b98c
|
99 |
url_data = Url().url2dic([insight.getLinkUrl(),message_url,insight.getContentCommentUrl()])[0] |
cfdd3d396
|
100 |
|
cd3f2b98c
|
101 102 103 104 |
sqlvalues += "'" + url_data['bitly_url'] + "', " sqlvalues += url_data['bitly_click'] + ", " sqlvalues += "'" + url_data['origin_url'] + "', " sqlvalues += url_data['piki_cid'] + ", " |
9a4ce3987
|
105 |
sqlvalues += url_data['rpiki_click'] + ", " |
cfdd3d396
|
106 |
|
c9e21b9c5
|
107 |
for list in lists: |
66b00f133
|
108 |
sqlprefix += "`" + list.replace(',','_') + "`, " |
66b00f133
|
109 |
sqlvalues += str(insight.getContentInsightByKey(list)) + ", " |
c9e21b9c5
|
110 111 |
sqlprefix = sqlprefix[:len(sqlprefix)-2] + ")" sqlvalues = sqlvalues[:len(sqlvalues)-2] + ");" |
003f69af3
|
112 |
#print sqlprefix + sqlvalues |
cfdd3d396
|
113 |
|
92dc7e4f8
|
114 115 |
datadb.fb_insert(sqlprefix + sqlvalues) datadb.fb_insert(sqlreplace + sqlprefix[32:] + sqlvalues) |
cfdd3d396
|
116 |
|
c9e21b9c5
|
117 |
|
4af77bd17
|
118 |
del(datadb) |
c9e21b9c5
|
119 |
del(insight) |
ae1adcd6e
|
120 |
|
208e177fc
|
121 |
|
fa7135c35
|
122 |