Skip to content
Projects
Groups
Snippets
Help
Loading...
Sign in
Toggle navigation
M
meta_base_code
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
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
宋柯
meta_base_code
Commits
29af2e6c
Commit
29af2e6c
authored
Nov 23, 2020
by
litaolemo
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
update
parent
f46acb3e
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
24 additions
and
21 deletions
+24
-21
spark_test.py
task/spark_test.py
+24
-21
No files found.
task/spark_test.py
View file @
29af2e6c
...
...
@@ -189,10 +189,13 @@ WHERE spam_pv.device_id IS NULL
if
portratit_res
[
demand
]:
try
:
for
tag
in
portratit_res
[
demand
][
0
:
3
]:
if
tag
in
portrait_dict
[
demand
]:
if
tag
==
"吸脂瘦下颌缘"
and
demand
==
"projects"
:
print
(
res
.
device_id
)
if
tag
in
portrait_dict
[
demand
]:
portrait_dict
[
demand
][
tag
]
+=
1
else
:
else
:
portrait_dict
[
demand
][
tag
]
=
1
except
Exception
as
e
:
print
(
"error "
,
e
)
...
...
@@ -206,27 +209,27 @@ WHERE spam_pv.device_id IS NULL
print
(
"-------------------------------"
)
for
protratit_type
in
portrait_dict
[
"projects"
]:
partition_date
=
today_str
pid
=
hashlib
.
md5
((
partition_date
+
protratit_type
)
.
encode
(
"utf8"
))
.
hexdigest
()
action_count
=
portrait_dict
[
"projects"
][
protratit_type
]
instert_sql
=
"""replace into new_user_project_count(
partition_day,pid,protratit_count,protratit_type) VALUES('{partition_day}','{pid}',{protratit_count},'{protratit_type}');"""
.
format
(
partition_day
=
today_str
,
pid
=
pid
,
protratit_count
=
action_count
,
protratit_type
=
protratit_type
)
print
(
instert_sql
)
# cursor.execute("set names 'UTF8'")
db
=
pymysql
.
connect
(
host
=
'172.16.40.158'
,
port
=
4000
,
user
=
'st_user'
,
passwd
=
'aqpuBLYzEV7tML5RPsN1pntUzFy'
,
db
=
'jerry_prod'
)
cursor
=
db
.
cursor
()
res
=
cursor
.
execute
(
instert_sql
)
db
.
commit
()
print
(
res
)
#
for protratit_type in portrait_dict["projects"]:
#
partition_date = today_str
#
pid = hashlib.md5((partition_date + protratit_type).encode("utf8")).hexdigest()
#
action_count = portrait_dict["projects"][protratit_type]
#
#
instert_sql = """replace into new_user_project_count(
#
partition_day,pid,protratit_count,protratit_type) VALUES('{partition_day}','{pid}',{protratit_count},'{protratit_type}');""".format(
#
partition_day=today_str, pid=pid, protratit_count=action_count
#
, protratit_type=protratit_type
#
)
#
print(instert_sql)
#
# cursor.execute("set names 'UTF8'")
#
db = pymysql.connect(host='172.16.40.158', port=4000, user='st_user', passwd='aqpuBLYzEV7tML5RPsN1pntUzFy',
#
db='jerry_prod')
#
cursor = db.cursor()
#
res = cursor.execute(instert_sql)
#
db.commit()
#
print(res)
# cursor.executemany()
db
.
close
()
#
db.close()
...
...
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