Mercurial > repos > bornea > saint_preproc
comparison SAINT_preprocessing_v6_mq_pep.py @ 9:9c3d2b1d0c1c draft
Uploaded
author | bornea |
---|---|
date | Tue, 10 Nov 2015 13:15:41 -0500 |
parents | |
children | 729aac64ce43 |
comparison
equal
deleted
inserted
replaced
8:30d53a378141 | 9:9c3d2b1d0c1c |
---|---|
1 ####################################################################################### | |
2 # Python-code: SAINT pre-processing from maxquant "Samples Report" output | |
3 # Author: Brent Kuenzi | |
4 ####################################################################################### | |
5 # This program reads in a raw maxquant "Samples Report" output and a user generated | |
6 # bait file and autoformats it into prey and interaction files for SAINTexpress | |
7 # analysis | |
8 ####################################################################################### | |
9 import sys | |
10 import urllib2 | |
11 import os | |
12 ####################################################################################### | |
13 ## REQUIRED INPUT ## | |
14 | |
15 # 1) infile: maxquant "Samples Report" output | |
16 # 2) baitfile: SAINT formatted bait file generated in Galaxy | |
17 # 3) prey: Y or N for generating a prey file (requires internet connection) | |
18 ####################################################################################### | |
19 mq_file = sys.argv[1] | |
20 cmd = r"Rscript /home/bornea/galaxy_moffitt_dev/tools/Moffitt_Tools/bubblebeam/pre_process_protein_name_set.R " + str(mq_file) | |
21 os.system(cmd) | |
22 | |
23 infile = "./tukeys_output.txt" #maxquant "Samples Report" output | |
24 prey = sys.argv[2] # Y or N | |
25 fasta_db = sys.argv[3] | |
26 if fasta_db == "None": | |
27 fasta_db = "/home/bornea/galaxy_moffitt_dev/tools/Moffitt_Tools/bubblebeam/SwissProt_HUMAN_2014_08.fasta" | |
28 make_bait= sys.argv[6] | |
29 | |
30 def bait_create(baits, infile): | |
31 #Takes the Bait specified by the user and makes them into a Bait file and includes a check to make sure they are using valid baits. | |
32 baits = make_bait.split() | |
33 i = 0 | |
34 bait_file_tmp = open("bait.txt", "wr") | |
35 order = [] | |
36 bait_cache = [] | |
37 while i < len(baits): | |
38 if baits[i+2] == "true": | |
39 T_C = "C" | |
40 else: | |
41 T_C = "T" | |
42 line1 = baits[i] + "\t" + baits[i+1] + "\t" + T_C + "\n" | |
43 q = open(infile,"r") | |
44 for line2 in q: | |
45 line2 = line2.replace("\"", "") | |
46 line2 = line2.replace(r"Intensity.", "") #R coerces "-" into "." this changes them back and remove Intensity from the Bait names. | |
47 line2 = line2.replace(r".", r"-") | |
48 temp = line2.split() | |
49 if "mapped_protein" in str(temp): | |
50 #If the bait is in the original file then write to cache it if not exit. | |
51 if baits[i] in temp: | |
52 number_bait = temp.index(str(baits[i])) | |
53 number_bait = number_bait - 9 | |
54 bait_cache.append((number_bait, str(line1))) | |
55 else: | |
56 print "Error: bad bait " + str(baits[i]) | |
57 sys.exit() | |
58 else: | |
59 pass | |
60 i = i + 3 | |
61 #Writes cache to file. | |
62 bait_cache.sort() | |
63 for line in bait_cache: | |
64 bait_file_tmp.write(line[1]) | |
65 | |
66 bait_file_tmp.close() | |
67 | |
68 | |
69 baitfile = "bait.txt" | |
70 | |
71 class ReturnValue1(object): | |
72 def __init__(self, sequence, gene): | |
73 self.seqlength = sequence | |
74 self.genename = gene | |
75 class ReturnValue2(object): | |
76 def __init__(self, getdata, getproteins, getheader): | |
77 self.data = getdata | |
78 self.proteins = getproteins | |
79 self.header = getheader | |
80 | |
81 def main(maxquant_input, make_bait): | |
82 bait_create(make_bait, infile) | |
83 baitfile = "bait.txt" | |
84 #bait_check(baitfile, maxquant_input) | |
85 make_inter(maxquant_input) | |
86 if prey == 'true': | |
87 make_prey(maxquant_input) | |
88 no_error_inter(maxquant_input) | |
89 os.rename('prey.txt', sys.argv[5]) | |
90 elif prey == 'false': | |
91 if os.path.isfile('error proteins.txt') == True: | |
92 no_error_inter(maxquant_input) | |
93 pass | |
94 elif prey != 'true' or 'false': | |
95 sys.exit("Invalid Prey Argument: Y or N") | |
96 os.rename('inter.txt', sys.argv[4]) | |
97 os.rename("bait.txt", sys.argv[7]) | |
98 | |
99 | |
100 def get_info(uniprot_accession_in): # get aa lengths and gene name | |
101 error = open('error proteins.txt', 'a+') | |
102 # while True: | |
103 # i = 0 | |
104 # try: | |
105 # data = urllib2.urlopen("http://www.uniprot.org/uniprot/" + uniprot_accession_in + ".fasta") | |
106 # break | |
107 # except urllib2.HTTPError, err: | |
108 # i = i + 1 | |
109 # if i == 50: | |
110 # sys.exit("More than 50 errors. Check your file or try again later.") | |
111 # if err.code == 404: | |
112 # error.write(uniprot_accession_in + '\t' + "Invalid URL. Check protein" + '\n') | |
113 # seqlength = 'NA' | |
114 # genename = 'NA' | |
115 # return ReturnValue1(seqlength, genename) | |
116 # elif err.code == 302: | |
117 # sys.exit("Request timed out. Check connection and try again.") | |
118 # else: | |
119 # sys.exit("Uniprot had some other error") | |
120 # | |
121 # | |
122 # if lines == []: | |
123 # error.write(uniprot_accession_in + '\t' + "Blank Fasta" + '\n') | |
124 # error.close | |
125 # if lines == []: | |
126 # error.write(uniprot_accession_in + '\t' + "Blank Fasta" + '\n') | |
127 # error.close | |
128 # seqlength = 'NA' | |
129 # genename = 'NA' | |
130 # return ReturnValue1(seqlength, genename) | |
131 # if lines != []: | |
132 # seqlength = 0 | |
133 # header = lines[0] | |
134 # for line in lines[1:]: | |
135 # line = line.replace("\n","") # strip \n or else it gets counted in the length | |
136 # seqlength += len(line) | |
137 # if 'GN=' in header: | |
138 # lst = header.split('GN=') | |
139 # lst2 = lst[1].split(' ') | |
140 # genename = lst2[0] | |
141 # error.close | |
142 # return ReturnValue1(seqlength, genename) | |
143 # if 'GN=' not in header: | |
144 # genename = 'NA' | |
145 # error.close | |
146 # return ReturnValue1(seqlength, genename) | |
147 | |
148 data = open(fasta_db,'r') | |
149 lines = data.readlines() | |
150 db_len = len(lines) | |
151 seqlength = 0 | |
152 count = 0 | |
153 for i in lines: | |
154 if ">sp" in i: | |
155 if uniprot_accession_in == i.split("|")[1]: | |
156 match = count+1 | |
157 if 'GN=' in i: | |
158 lst = i.split('GN=') | |
159 lst2 = lst[1].split(' ') | |
160 genename = lst2[0] | |
161 if 'GN=' not in i: | |
162 genename = 'NA' | |
163 while ">sp" not in lines[match]: | |
164 if match <= db_len: | |
165 seqlength = seqlength + len(lines[match].strip()) | |
166 match = match + 1 | |
167 else: | |
168 break | |
169 return ReturnValue1(seqlength, genename) | |
170 count = count + 1 | |
171 | |
172 | |
173 if seqlength == 0: | |
174 error.write(uniprot_accession_in + '\t' + "Uniprot not in Fasta" + '\n') | |
175 error.close | |
176 seqlength = 'NA' | |
177 genename = 'NA' | |
178 return ReturnValue1(seqlength, genename) | |
179 | |
180 | |
181 def readtab(infile): | |
182 with open(infile,'r') as x: # read in tab-delim text | |
183 output = [] | |
184 for line in x: | |
185 line = line.strip() | |
186 temp = line.split('\t') | |
187 output.append(temp) | |
188 return output | |
189 def read_maxquant(maxquant_input): # Get data, proteins and header from maxquant output | |
190 dupes = readtab(maxquant_input) | |
191 header_start = 0 | |
192 header = dupes[header_start] | |
193 for i in header: | |
194 i = i.replace(r"\"", "") | |
195 i = i.replace(r"Intensity.", r"") | |
196 i = i.replace(r".", r"-") | |
197 data = dupes[header_start+1:len(dupes)] #cut off blank line and END OF FILE | |
198 proteins = [] | |
199 for protein in data: | |
200 proteins.append(protein[0]) | |
201 return ReturnValue2(data, proteins, header) | |
202 def make_inter(maxquant_input): | |
203 bait = readtab(baitfile) | |
204 data = read_maxquant(maxquant_input).data | |
205 header = read_maxquant(maxquant_input).header | |
206 proteins = read_maxquant(maxquant_input).proteins | |
207 bait_index = [] | |
208 for i in bait: | |
209 bait_index.append(header.index("mapped_protein") + 1) # Find just the baits defined in bait file | |
210 with open('inter.txt', 'w') as y: | |
211 a = 0; l=0 | |
212 for bb in bait: | |
213 for lst in data: | |
214 y.write(header[bait_index[l]] + '\t' + bb[1] + '\t' + proteins[a] + '\t' + lst[bait_index[l]] + '\n') | |
215 a+=1 | |
216 if a == len(proteins): | |
217 a = 0; l+=1 | |
218 def make_prey(maxquant_input): | |
219 proteins = read_maxquant(maxquant_input).proteins | |
220 output_file = open("prey.txt",'w') | |
221 for a in proteins: | |
222 a = a.replace("\n","") # remove \n for input into function | |
223 a = a.replace("\r","") # ditto for \r | |
224 seq = get_info(a).seqlength | |
225 GN = get_info(a).genename | |
226 if seq != 'NA': | |
227 output_file.write(a+"\t"+str(seq)+ "\t" + str(GN) + "\n") | |
228 output_file.close() | |
229 def no_error_inter(maxquant_input): # remake inter file without protein errors from Uniprot | |
230 err = readtab("error proteins.txt") | |
231 bait = readtab(baitfile) | |
232 data = read_maxquant(maxquant_input).data | |
233 header = read_maxquant(maxquant_input).header | |
234 header = [i.replace(r"\"", "") for i in header] | |
235 header = [i.replace(r"Intensity.", r"") for i in header] | |
236 header = [i.replace(r".", r"-") for i in header] | |
237 print header | |
238 bait_index = [] | |
239 for i in bait: | |
240 bait_index.append(header.index(i[0])) | |
241 proteins = read_maxquant(maxquant_input).proteins | |
242 errors = [] | |
243 for e in err: | |
244 errors.append(e[0]) | |
245 with open('inter.txt', 'w') as y: | |
246 l = 0; a = 0 | |
247 for bb in bait: | |
248 for lst in data: | |
249 if proteins[a] not in errors: | |
250 y.write(header[bait_index[l]] + '\t' + bb[1] + '\t' + proteins[a] + '\t' + lst[bait_index[l]] + '\n') | |
251 a+=1 | |
252 if a == len(proteins): | |
253 l += 1; a = 0 | |
254 def bait_check(bait, maxquant_input): # check that bait names share header titles | |
255 bait_in = readtab(bait) | |
256 header = read_maxquant(maxquant_input).header | |
257 for i in bait_in: | |
258 if i[0] not in header: | |
259 sys.exit("Bait must share header titles with maxquant output") | |
260 | |
261 if __name__ == '__main__': | |
262 main(infile, make_bait) |