UnknownSourcing

View or edit on GitHub

This page is synchronized from trase/models/indonesia/palm_oil/UnknownSourcing.ipynb. Last modified on 2025-12-14 23:19 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).

from trase.tools.pcs import *
import pandas as pd

for year in [2018, 2019, 2020]:
    df = pd.read_csv(f"{year}/results/results_KM_0_MGD_30.csv", delimiter=";")
    #     df_concessions = pd.read_csv(f"{year}/prepared/concession.csv", delimiter=";").drop(columns="vol")
    #     df = pd.merge(df, df_concessions, on="concession")
    add_all_nodes_in_country_to_cache(get_country_id("INDONESIA"))
    df = df[df["branch"].str.contains("LP 2")]
    df["kabupaten"] = df["concession"].apply(
        lambda x: get_trase_id(
            get_parent(find_node_by_trase_id(x.replace("FFB", "ID-PALM-CONCESSION")), 4)
        )
    )
    df = (
        df.groupby(["concession", "kabupaten", "province", "mill_id"])["vol"]
        .sum()
        .reset_index()
    )
    df["fraction"] = df["vol"] / df["vol"].sum()
    df = df.drop(columns="vol")
    df.to_csv(f"UNKNOWN_SOURCING_{year}.csv")

df["fraction"].sum()

import pandas as pd

df = pd.read_csv(f"2018/prepared/exporter_mill.csv", delimiter=";")
df[df["exporter_id"] == "E-0055"]