Unknowns

View or edit on GitHub

This page is synchronized from trase/models/brazil/beef/Unknowns.ipynb. Last modified on 2026-03-21 22:30 CET by Trase Admin. Please view or edit the original file there; changes should be reflected here after a midnight build (CET time), or manually triggering it with a GitHub action (link).

import pandas as pd
from trase.tools.pcs import (
    find_node_by_trase_id,
    NoDataError,
    insert_node,
    get_node_name,
    get_node_type_id,
    get_node_sub_type_id,
)

for year in range(2010, 2021):
    print()
    print(year)
    df = pd.read_csv(f"{year}/results/results.csv", sep=";")
    for _, row in (
        df[["LOGISTICS_HUB", "LOGISTICS_HUB_TRASE_ID"]].drop_duplicates().iterrows()
    ):
        trase_id = row["LOGISTICS_HUB_TRASE_ID"]
        try:
            node_id = find_node_by_trase_id(trase_id)
        except NoDataError:
            print(trase_id)
            municipality_trase_id = row["LOGISTICS_HUB"]
            trader_trase_id = "BR-TRADER-" + trase_id.split("-")[-1][:8]
            name = f"{get_node_name(find_node_by_trase_id(trader_trase_id))} {get_node_name(find_node_by_trase_id(municipality_trase_id))} SLAUGHTERHOUSE"
            print("need to insert", name, trase_id)
            node_id = insert_node(
                name,
                node_type_id=get_node_type_id("PROCESSING ASSET"),
                sub_type_id=get_node_sub_type_id("SLAUGHTERHOUSE"),
                parent_id=find_node_by_trase_id(municipality_trase_id),
                trase_id=trase_id,
            )
import pandas as pd
from trase.tools.pcs import (
    find_node_by_trase_id,
    NoDataError,
    insert_node,
    get_node_name,
    get_node_type_id,
    get_node_sub_type_id,
)
from trase.tools.sps import consolidate

for year in range(2010, 2021):
    print()
    print(year)
    df = pd.read_csv(f"{year}/results/results.csv", sep=";")

    df = df.groupby("HS6")["VOLUME_RAW", "VOLUME_PRODUCT"].sum().reset_index()
    df["ratio"] = df["VOLUME_RAW"] / df["VOLUME_PRODUCT"]
    print(df)