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.