mzml.py 文件源码

def mzmlToSqlite(xmlfile, sqlitefile):
    parser = xml.iterparse(xmlfile)

    writeQueue = multiprocessing.Queue()
    writerProc = multiprocessing.Process(target = mzmlToSqlite_writer,
                                         args = (sqlitefile, writeQueue))
    writerProc.start()


    for evt, obj in parser:
        if obj.tag == ns('spectrum'):
            writeQueue.put(('spectrum', readSpectrumXML(obj)))
            obj.clear()
        elif obj.tag == ns('chromatogram'):
            writeQueue.put(('chromatogram', readChromatoXML(obj)))
            obj.clear()

    writeQueue.put(('stop', None))

    writerProc.join()
    return sqlitefile