IPP Software Navigation Tools IPP Links Communication Pan-STARRS Links

Ignore:
Timestamp:
Jan 22, 2013, 9:43:22 AM (13 years ago)
Author:
eugene
Message:

add dvopsps-based method to ingest detections; do not use foreign key constraint if using dvopsps

File:
1 edited

Legend:

Unmodified
Added
Removed
  • branches/eam_branches/ipp-20121219/ippToPsps/jython/dvo.py

    r34988 r35016  
    562562      return tableName
    563563
     564
     565    '''
     566    ingest skyregion into MySQL database using the native DVO program dvopsps
     567    Populates dvoDetections and dvoDone with FITS tables from DVO for the defined sky area, this
     568    includes purging detections outside sky area
     569    '''
     570    def nativeIngestDetections(self, raCenter, decCenter, boxSize):
     571
     572        # self.scratchDb.resetAllDvoTables()
     573
     574        # make sure we have an up-to-date Images table
     575        self.loadImages()
     576
     577        # XXX blow away existing dvoDetection table?
     578
     579        # dvopsps -D catdir CATDIR -region .... -dbhost xx -dbname xx -dbuser xx -dbpass xx
     580        halfSize = boxSize / 2.0
     581        # -region raCenter-halfSize raCenter+halfSize decCenter-halfSize decCenter+halfSize
     582
     583        # TODO path to DVO prog hardcoded temporarily
     584        cmd = "dvopsps detections"
     585        cmd += " -dbhost " + self.scratchDb.dbHost
     586        cmd += " -dbname " + self.scratchDb.dbName
     587        cmd += " -dbuser " + self.scratchDb.dbUser
     588        cmd += " -dbpass " + self.scratchDb.dbPass
     589        cmd += " -D CATDIR " + self.config.dvoLocation
     590        cmd += " -region "
     591        cmd += " " + str(raCenter-halfSize)
     592        cmd += " " + str(raCenter+halfSize)
     593        cmd += " " + str(decCenter-halfSize)
     594        cmd += " " + str(decCenter+halfSize)
     595
     596        self.logger.infoPair("Running dvopsps", cmd)
     597        p = Popen(cmd, shell=True, stdout=PIPE)
     598        p.wait()
     599
     600
     601        # update lists after attempted sync
     602        # self.printSummary()
     603
     604        return True
Note: See TracChangeset for help on using the changeset viewer.