Module trase.tools.pcs.supply_chains.flows.insert

Functions

def insert_flow(path,
commodity_id,
volume,
ref_id,
commodity_equivalence_group_id,
commodity_equivalence_factor_ids=None,
year=None,
month=None,
day=None,
time_start=None,
time_end=None,
quants=None,
quals=None,
inds=None,
step_quants=None,
step_quals=None,
step_inds=None,
autocommit=True,
cnx=None,
cur=None)

Insert flow into database.

:param path: list of 'nodes.node_id' :type path: list[int] :param commodity_id: 'coms.commodity_id' in database :type commodity_id: int or list[int] :param volume: volume :type volume: float or list[float] :param int ref_id: 'refs.ref_id' in database :param int year: year: required when time_start and time_end are not provided :param int month: month; optional when year is provided :param int day: day; optional when year and month are provided :param time_start: required when year is not provided :type time_start: datetime.datetime :param time_end: required when year is not provided :type time_end: datetime.datetime :param quants: dictionary of {quant_id: quant_value} :type quants: dict[int, float] :param quals: dictionary of {qual_id: qual_value} :type quals: dict[int, str] :param inds: dictionary of {ind_id: ind_value} :type inds: dict[int, float] :param cnx: Database connection object :type cnx: psycopg2.extensions.connection or pcs.connect.loggingConnection :param cur: Database cursor object :type cur: psycopg2.extensions.cursor or pcs.connect.loggingCursor :return: flow id :rtype: int

def insert_flows(flow_values_list, ref_id, autocommit=True, cnx=None, cur=None)

Insert multiple flows.

def make_flow_values(path,
commodity_id,
volume,
ref_id,
commodity_equivalence_group_id,
commodity_equivalence_factor_ids=None,
year=None,
month=None,
day=None,
time_start=None,
time_end=None,
quants=None,
quals=None,
inds=None,
step_quants=None,
step_quals=None,
step_inds=None,
cur=None)

Return dictionary of value for flow.