Mercurial > repos > yufei-luo > s_mart
comparison smart_toolShed/SMART/Java/Python/getRandomRegions.py @ 0:e0f8dcca02ed
Uploaded S-MART tool. A toolbox manages RNA-Seq and ChIP-Seq data.
| author | yufei-luo |
|---|---|
| date | Thu, 17 Jan 2013 10:52:14 -0500 |
| parents | |
| children |
comparison
equal
deleted
inserted
replaced
| -1:000000000000 | 0:e0f8dcca02ed |
|---|---|
| 1 #! /usr/bin/env python | |
| 2 # | |
| 3 # Copyright INRA-URGI 2009-2010 | |
| 4 # | |
| 5 # This software is governed by the CeCILL license under French law and | |
| 6 # abiding by the rules of distribution of free software. You can use, | |
| 7 # modify and/ or redistribute the software under the terms of the CeCILL | |
| 8 # license as circulated by CEA, CNRS and INRIA at the following URL | |
| 9 # "http://www.cecill.info". | |
| 10 # | |
| 11 # As a counterpart to the access to the source code and rights to copy, | |
| 12 # modify and redistribute granted by the license, users are provided only | |
| 13 # with a limited warranty and the software's author, the holder of the | |
| 14 # economic rights, and the successive licensors have only limited | |
| 15 # liability. | |
| 16 # | |
| 17 # In this respect, the user's attention is drawn to the risks associated | |
| 18 # with loading, using, modifying and/or developing or reproducing the | |
| 19 # software by the user in light of its specific status of free software, | |
| 20 # that may mean that it is complicated to manipulate, and that also | |
| 21 # therefore means that it is reserved for developers and experienced | |
| 22 # professionals having in-depth computer knowledge. Users are therefore | |
| 23 # encouraged to load and test the software's suitability as regards their | |
| 24 # requirements in conditions enabling the security of their systems and/or | |
| 25 # data to be ensured and, more generally, to use and operate it in the | |
| 26 # same conditions as regards security. | |
| 27 # | |
| 28 # The fact that you are presently reading this means that you have had | |
| 29 # knowledge of the CeCILL license and that you accept its terms. | |
| 30 # | |
| 31 """Find random regions in a genome""" | |
| 32 | |
| 33 import random, math | |
| 34 from optparse import OptionParser | |
| 35 from commons.core.parsing.FastaParser import * | |
| 36 from commons.core.writer.Gff3Writer import * | |
| 37 from commons.core.writer.MySqlTranscriptWriter import * | |
| 38 from SMART.Java.Python.misc.Progress import * | |
| 39 from SMART.Java.Python.structure.Transcript import Transcript | |
| 40 from SMART.Java.Python.structure.TranscriptContainer import TranscriptContainer | |
| 41 | |
| 42 repetitions = 100 | |
| 43 | |
| 44 | |
| 45 class RandomRegionsGenerator(object): | |
| 46 | |
| 47 def __init__(self, verbosity): | |
| 48 self.verbosity = verbosity | |
| 49 self.strands = False | |
| 50 self.distribution = "uniform" | |
| 51 self.transcripts = None | |
| 52 self.sequenceParser = None | |
| 53 random.seed() | |
| 54 | |
| 55 | |
| 56 def setInput(self, fileName): | |
| 57 self.sequenceParser = FastaParser(fileName, self.verbosity) | |
| 58 | |
| 59 | |
| 60 def setGenomeSize(self, size): | |
| 61 self.genomeSize = size | |
| 62 | |
| 63 | |
| 64 def setChromosomeName(self, name): | |
| 65 self.chromosomeName = name | |
| 66 | |
| 67 | |
| 68 def setAnnotation(self, fileName, format): | |
| 69 parser = TranscriptContainer(fileName, format, self.verbosity) | |
| 70 self.transcripts = [] | |
| 71 for transcript in parser.getIterator(): | |
| 72 self.transcripts.append(transcript) | |
| 73 self.setNumber(len(self.transcripts)) | |
| 74 self.setSize(0) | |
| 75 | |
| 76 | |
| 77 def setOutputFile(self, fileName): | |
| 78 self.outputFileName = fileName | |
| 79 | |
| 80 | |
| 81 def setSize(self, size): | |
| 82 self.minSize = size | |
| 83 self.maxSize = size | |
| 84 | |
| 85 | |
| 86 def setMinSize(self, size): | |
| 87 self.minSize = size | |
| 88 | |
| 89 | |
| 90 def setMaxSize(self, size): | |
| 91 self.maxSize = size | |
| 92 | |
| 93 | |
| 94 def setNumber(self, number): | |
| 95 self.number = number | |
| 96 | |
| 97 | |
| 98 def setStrands(self, strands): | |
| 99 self.strands = strands | |
| 100 | |
| 101 | |
| 102 def setMaxDistribution(self, maxElements): | |
| 103 if maxElements == None: | |
| 104 return | |
| 105 self.maxElements = maxElements | |
| 106 self.distribution = "gaussian" | |
| 107 | |
| 108 | |
| 109 def setDeviationDistribution(self, deviation): | |
| 110 if deviation == None: | |
| 111 return | |
| 112 self.deviation = deviation | |
| 113 self.distribution = "gaussian" | |
| 114 | |
| 115 | |
| 116 def getSizes(self): | |
| 117 if self.sequenceParser == None: | |
| 118 self.chromosomes = [self.chromosomeName] | |
| 119 self.sizes = {self.chromosomeName: self.genomeSize} | |
| 120 self.cumulatedSize = self.genomeSize | |
| 121 self.cumulatedSizes = {self.chromosomeName: self.genomeSize} | |
| 122 return | |
| 123 self.chromosomes = self.sequenceParser.getRegions() | |
| 124 self.sizes = {} | |
| 125 self.cumulatedSize = 0 | |
| 126 self.cumulatedSizes = {} | |
| 127 for chromosome in self.chromosomes: | |
| 128 self.sizes[chromosome] = self.sequenceParser.getSizeOfRegion(chromosome) | |
| 129 self.cumulatedSize += self.sizes[chromosome] | |
| 130 self.cumulatedSizes[chromosome] = self.cumulatedSize | |
| 131 | |
| 132 | |
| 133 def findPosition(self, size = None): | |
| 134 if size == None: | |
| 135 size = random.randint(self.minSize, self.maxSize) | |
| 136 integer = random.randint(0, self.cumulatedSize) | |
| 137 for chromosome in self.chromosomes: | |
| 138 if self.cumulatedSizes[chromosome] > integer: | |
| 139 break | |
| 140 start = random.randint(1, self.sizes[chromosome] - size) | |
| 141 return (chromosome, start, size) | |
| 142 | |
| 143 | |
| 144 def createTranscript(self, chromosome, start, size, strand, cpt): | |
| 145 transcript = Transcript() | |
| 146 transcript.setChromosome(chromosome) | |
| 147 transcript.setStart(start) | |
| 148 transcript.setEnd(start + size-1) | |
| 149 transcript.setDirection(strand) | |
| 150 transcript.setName("rand_%d" % (cpt)) | |
| 151 return transcript | |
| 152 | |
| 153 | |
| 154 def moveTranscript(self, chromosome, start, transcript): | |
| 155 while transcript.getEnd() + start - transcript.getStart() > self.cumulatedSizes[chromosome]: | |
| 156 chromosome, start, size = self.findPosition(transcript.getEnd() - transcript.getStart()) | |
| 157 transcript.setChromosome(chromosome) | |
| 158 oldStart, oldEnd = transcript.getStart(), transcript.getEnd() | |
| 159 if transcript.getNbExons() > 1: | |
| 160 for exon in transcript.getNbExons(): | |
| 161 oldExonStart, oldExonEnd = exon.getStart(), exon.getEnd() | |
| 162 exon.setStart(oldExonStart + start - oldStart) | |
| 163 exon.setEnd(oldExonEnd + start - oldStart) | |
| 164 transcript.setStart(start) | |
| 165 transcript.setEnd(oldEnd + start - oldStart) | |
| 166 return [transcript] | |
| 167 | |
| 168 | |
| 169 def createUniformCluster(self, chromosome, start, size, strand, cpt): | |
| 170 transcript = self.createTranscript(chromosome, start, size, strand, cpt) | |
| 171 return [transcript] | |
| 172 | |
| 173 | |
| 174 def findNbTranscripts(self, cpt): | |
| 175 return min(int(round(math.exp(random.random() * math.log(self.maxElements)))), self.number - cpt + 1) | |
| 176 | |
| 177 | |
| 178 def getDev(self): | |
| 179 deviation = 0.0 | |
| 180 for j in range(repetitions): | |
| 181 deviation += random.randint(-self.deviation, self.deviation) | |
| 182 deviation /= repetitions | |
| 183 deviation = int(round(deviation)) | |
| 184 return deviation | |
| 185 | |
| 186 | |
| 187 def createGaussianCluster(self, chromosome, start, size, strand, cpt): | |
| 188 transcripts = [] | |
| 189 nbTranscripts = self.findNbTranscripts(cpt) | |
| 190 for i in range(nbTranscripts): | |
| 191 transcript = self.createTranscript(chromosome, start + self.getDev(), size + self.getDev(), strand, cpt + i) | |
| 192 transcripts.append(transcript) | |
| 193 return transcripts | |
| 194 | |
| 195 | |
| 196 def writeRegions(self): | |
| 197 writer = Gff3Writer(self.outputFileName, self.verbosity) | |
| 198 outputFile = open(self.outputFileName, "w") | |
| 199 progress = Progress(self.number, "Writing to %s" % (self.outputFileName), self.verbosity) | |
| 200 i = 0 | |
| 201 while i < self.number: | |
| 202 chromosome, start, size = self.findPosition() | |
| 203 strand = random.choice([-1, 1]) if self.strands else 1 | |
| 204 if self.transcripts != None: | |
| 205 transcripts = self.moveTranscript(chromosome, start, self.transcripts[i]) | |
| 206 elif self.distribution == "uniform": | |
| 207 transcripts = self.createUniformCluster(chromosome, start, size, strand, i+1) | |
| 208 else: | |
| 209 transcripts = self.createGaussianCluster(chromosome, start, size, strand, i+1) | |
| 210 for transcript in transcripts: | |
| 211 writer.addTranscript(transcript) | |
| 212 i += 1 | |
| 213 progress.inc() | |
| 214 progress.done() | |
| 215 outputFile.close() | |
| 216 writer.write() | |
| 217 writer.close() | |
| 218 | |
| 219 | |
| 220 def run(self): | |
| 221 self.getSizes() | |
| 222 self.writeRegions() | |
| 223 | |
| 224 | |
| 225 if __name__ == "__main__": | |
| 226 | |
| 227 # parse command line | |
| 228 description = "Get Random Regions v1.0.2: Get some random coordinates on a genome. May use uniform or gaussian distribution (in gaussion distribution, # of element per cluster follows a power law). [Category: Other]" | |
| 229 | |
| 230 parser = OptionParser(description = description) | |
| 231 parser.add_option("-r", "--reference", dest="reference", action="store", default=None, type="string", help="file that contains the sequences [format: file in FASTA format]") | |
| 232 parser.add_option("-S", "--referenceSize", dest="referenceSize", action="store", default=None, type="int", help="size of the chromosome (when no reference is given) [format: int]") | |
| 233 parser.add_option("-c", "--chromosome", dest="chromosome", action="store", default=None, type="string", help="name of the chromosome (when no reference is given) [format: string]") | |
| 234 parser.add_option("-o", "--output", dest="outputFileName", action="store", type="string", help="output file [compulsory] [format: output file in FASTA format]") | |
| 235 parser.add_option("-i", "--input", dest="inputFileName", action="store", default=None, type="string", help="optional file containing regions to shuffle [format: file in transcript format given by -f]") | |
| 236 parser.add_option("-f", "--format", dest="format", action="store", default=None, type="string", help="format of the previous file [format: transcript file format]") | |
| 237 parser.add_option("-s", "--size", dest="size", action="store", default=None, type="int", help="size of the regions (if no region set is provided) [format: int]") | |
| 238 parser.add_option("-z", "--minSize", dest="minSize", action="store", default=None, type="int", help="minimum size of the regions (if no region set nor a fixed size are provided) [format: int]") | |
| 239 parser.add_option("-Z", "--maxSize", dest="maxSize", action="store", default=None, type="int", help="maximum size of the regions (if no region set nor a fixed size are provided) [format: int]") | |
| 240 parser.add_option("-n", "--number", dest="number", action="store", default=None, type="int", help="number of regions (if no region set is provided) [format: int]") | |
| 241 parser.add_option("-t", "--strands", dest="strands", action="store_true", default=False, help="use both strands (if no region set is provided) [format: boolean]") | |
| 242 parser.add_option("-m", "--max", dest="max", action="store", default=None, type="int", help="max. # reads in a cluster (for Gaussian dist.) [format: int]") | |
| 243 parser.add_option("-d", "--deviation", dest="deviation", action="store", default=None, type="int", help="deviation around the center of the cluster (for Gaussian dist.) [format: int]") | |
| 244 parser.add_option("-v", "--verbosity", dest="verbosity", action="store", default=1, type="int", help="trace level [format: int]") | |
| 245 (options, args) = parser.parse_args() | |
| 246 | |
| 247 rrg = RandomRegionsGenerator(options.verbosity) | |
| 248 if options.reference == None: | |
| 249 rrg.setGenomeSize(options.referenceSize) | |
| 250 rrg.setChromosomeName(options.chromosome) | |
| 251 else: | |
| 252 rrg.setInput(options.reference) | |
| 253 rrg.setOutputFile(options.outputFileName) | |
| 254 if options.inputFileName == None: | |
| 255 if options.size != None: | |
| 256 rrg.setSize(options.size) | |
| 257 else: | |
| 258 rrg.setMinSize(options.minSize) | |
| 259 rrg.setMaxSize(options.maxSize) | |
| 260 rrg.setNumber(options.number) | |
| 261 rrg.setStrands(options.strands) | |
| 262 else: | |
| 263 rrg.setAnnotation(options.inputFileName, options.format) | |
| 264 rrg.setMaxDistribution(options.max) | |
| 265 rrg.setDeviationDistribution(options.deviation) | |
| 266 rrg.run() | |
| 267 |
