5
5
import csv
6
6
import io
7
7
8
-
8
+ ENCODING = "Latin-1"
9
+
9
10
def convertToCSV (jsonData , keys ):
10
11
returnData = {}
11
12
global counter
@@ -46,7 +47,7 @@ def convertToCSV(jsonData, keys):
46
47
return returnData
47
48
48
49
def writeCSV (a , filename ):
49
- write = csv .writer (io .open (filename , 'w' , newline = '' , encoding = 'Latin-1' ))
50
+ write = csv .writer (io .open (filename , 'w' , newline = '' , encoding = ENCODING ))
50
51
groups = ["cited_patents" ,"inventors" ,"application_citations" ,
51
52
"applications" , "assignees" ,"citedby_patents" ,"coinventors" ,
52
53
"cpc_subgroups" , "cpc_subsections" , "cpcs" , "IPCs" ,
@@ -80,7 +81,7 @@ def writeCSV(a, filename):
80
81
flag = True
81
82
if (flag ):
82
83
try :
83
- row = [str (s ).encode ("Latin-1" , "replace" ).decode ('cp1252 ' ) for s in row ]
84
+ row = [str (s ).encode (ENCODING , "replace" ).decode (ENCODING , errors = 'ignore ' ) for s in row ]
84
85
except :
85
86
pass
86
87
write .writerow (row )
@@ -89,10 +90,10 @@ def writeCSV(a, filename):
89
90
def merge_csv (fd ,q ,requests ):
90
91
diri = [d for d in os .listdir (fd ) if re .search (q + '_\d+.csv' ,d )]
91
92
csv_out = open (os .path .join (fd , q + '.csv' ), 'w' )
92
- for line in open (os .path .join (fd ,q + '_0.csv' )):
93
+ for line in open (os .path .join (fd ,q + '_0.csv' ), 'rb' ). read (). decode ( ENCODING , errors = 'ignore' ):
93
94
csv_out .write (line )
94
95
for i in range (requests ):
95
- f = open (os .path .join (fd , q + '_' + str (i )+ '.csv' ), 'r+' , encoding = 'Latin-1' )
96
+ f = open (os .path .join (fd , q + '_' + str (i )+ '.csv' ), 'r+' , encoding = ENCODING )
96
97
if sys .version_info >= (3 ,):
97
98
next (f )
98
99
else :
0 commit comments