nenupy.observation.sqldatabase


SQL Database

Query obs containing 19 antennas in database:

SELECT * FROM observation o

inner join analogbeam a on o.id = a.observation_id

where a.nAntennas = 19;

Query obs containing MA 55 in database:

select * from observation o inner join analogbeam a

on o.id = a.observation_id inner join mini_array_association aa

on a.id = aa.analog_beam_id inner join miniarray ma

on ma.id = aa.mini_array_id

where ma.name = 55;

from nenupy.observation import ParsetDataBase from nenupy.observation import Parset from sqlalchemy import create_engine import os

os.remove(‘/Users/aloh/Desktop/ma_base.db’) db = ParsetDataBase(dataBaseName=’/Users/aloh/Desktop/ma_base.db’)#, engine=create_engine(‘mysql:///’)) parset = Parset(‘/Users/aloh/Desktop/es11-2021-06-04-crab.parset’) parset.addToDatabase(data_base=db) parset2 = Parset(‘/Users/aloh/Desktop/parset/test_alan.parset’) parset2.addToDatabase(data_base=db)

class nenupy.observation.sqldatabase.AnalogBeamTable(**kwargs)[source]

Bases: Base

beam_squint_freq_mhz
dec_j2000
id
mini_arrays
observed_coord_type
observed_pointing_type
ra_j2000
scheduling
scheduling_id
start_time
stop_time
class nenupy.observation.sqldatabase.DigitalBeamTable(**kwargs)[source]

Bases: Base

anabeam
anabeam_id
dec_j2000
freq_max_mhz
freq_min_mhz
id
observed_coord_type
observed_pointing_type
processing
ra_j2000
start_time
stop_time
subbands
class nenupy.observation.sqldatabase.ParsetDataBase(database_name, engine=None, session=None)[source]

Bases: object

add_row(parset_property, desc)[source]
create_association_tables()[source]
create_configuration_tables()[source]

Creates the tables ‘mini_arrays’, ‘antennas’, ‘sub-bands’ and ‘receivers’.

delete_row(scheduling_id)[source]
done()[source]
classmethod from_existing_database(engine)[source]
classmethod new(database_name='my_base.db', engine=None)[source]
property parset
class nenupy.observation.sqldatabase.SchedulingTable(**kwargs)[source]

Bases: Base

abortTime
checkTime
checker_username
comments
endTime
fileName
id
name
nickel_subbands
other_error
path
receivers
startTime
state
status
submitTime
tags
token
topic
type
username