lsst.dax.apdb.sql.apdbSql Namespace Reference

Classes
class	ApdbSql

Functions
pandas.DataFrame	_coerce_uint64 (pandas.DataFrame df)
float	_make_midpointMjdTai_start (astropy.time.Time visit_time, int months)
None	_onSqlite3Connect (sqlite3.Connection dbapiConnection, sqlalchemy.pool._ConnectionRecord connectionRecord)

Variables
	_LOG = logging.getLogger(__name__)
	_MON = MonAgent(__name__)
	VERSION = VersionTuple(1, 1, 0)

Detailed Description

Module defining Apdb class and related methods.

Function Documentation

_coerce_uint64()

pandas.DataFrame lsst.dax.apdb.sql.apdbSql._coerce_uint64 ( pandas.DataFrame df )

protected

Change the type of uint64 columns to int64, and return copy of data
frame.

Definition at line 80 of file apdbSql.py.

def _coerce_uint64(df: pandas.DataFrame) -> pandas.DataFrame:
    """Change the type of uint64 columns to int64, and return copy of data
    frame.
    """
    names = [c[0] for c in df.dtypes.items() if c[1] == np.uint64]
    return df.astype(dict.fromkeys(names, np.int64))
 
 

_make_midpointMjdTai_start()

float lsst.dax.apdb.sql.apdbSql._make_midpointMjdTai_start ( astropy.time.Time visit_time, int months )

protected

Calculate starting point for time-based source search.

Parameters
----------
visit_time : `astropy.time.Time`
    Time of current visit.
months : `int`
    Number of months in the sources history.

Returns
-------
time : `float`
    A ``midpointMjdTai`` starting point, MJD time.

Definition at line 88 of file apdbSql.py.

def _make_midpointMjdTai_start(visit_time: astropy.time.Time, months: int) -> float:
    """Calculate starting point for time-based source search.
 
    Parameters
    ----------
    visit_time : `astropy.time.Time`
        Time of current visit.
    months : `int`
        Number of months in the sources history.
 
    Returns
    -------
    time : `float`
        A ``midpointMjdTai`` starting point, MJD time.
    """
    # TODO: Use of MJD must be consistent with the code in ap_association
    # (see DM-31996)
    return float(visit_time.mjd - months * 30)
 
 

_onSqlite3Connect()

None lsst.dax.apdb.sql.apdbSql._onSqlite3Connect ( sqlite3.Connection dbapiConnection, sqlalchemy.pool._ConnectionRecord connectionRecord )

protected

Definition at line 108 of file apdbSql.py.

) -> None:
    # Enable foreign keys
    with closing(dbapiConnection.cursor()) as cursor:
        cursor.execute("PRAGMA foreign_keys=ON;")
 
 

Variable Documentation

_LOG

lsst.dax.apdb.sql.apdbSql._LOG = logging.getLogger(__name__)

protected

Definition at line 69 of file apdbSql.py.

_MON

lsst.dax.apdb.sql.apdbSql._MON = MonAgent(__name__)

protected

Definition at line 71 of file apdbSql.py.

VERSION

lsst.dax.apdb.sql.apdbSql.VERSION = VersionTuple(1, 1, 0)

Definition at line 73 of file apdbSql.py.