Skip to content
Projects
Groups
Snippets
Help
Loading...
Sign in
Toggle navigation
F
ffm-baseline
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
ML
ffm-baseline
Commits
b9a7c4ab
Commit
b9a7c4ab
authored
Aug 22, 2018
by
张彦钊
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
add print
parent
4fe1114a
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
4 additions
and
6 deletions
+4
-6
diaryQueueUpdate.py
diaryQueueUpdate.py
+4
-6
No files found.
diaryQueueUpdate.py
View file @
b9a7c4ab
...
...
@@ -129,16 +129,14 @@ def merge_score(x_list, score_df):
# 去除diary_id 前面的"diary|"
x_list
=
tuple
(
list
(
map
(
lambda
x
:
x
[
6
:],
x_list
)))
start
=
time
.
time
()
print
(
x_list
[:
10
])
print
(
x_list
)
# TODO 把id也取下来,这样可以解决分数不匹配的问题
sql
=
"select score from biz_feed_diary_score where diary_id in {};"
.
format
(
x_list
)
cursor
.
execute
(
sql
)
result
=
cursor
.
fetchall
()
print
(
"获取成功"
)
score_list
=
list
(
result
)
print
(
score_list
)
#score_list = []
# for i in x_list:
# sql = "select score from biz_feed_diary_score where diary_id = '{}';".format(i)
...
...
@@ -153,9 +151,9 @@ def merge_score(x_list, score_df):
# score_list.append(0)
db
.
close
()
end
=
time
.
time
()
score_df
[
"score"
]
=
score_df
[
"score"
]
+
score_list
print
(
"更新分数耗时:{}分"
.
format
((
end
-
start
)
/
60
))
update_dairy_queue
(
score_df
)
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment