eeeck/CANveyor
1
0
Fork 0
Code Issues 1 Pull Requests Projects Releases 6 Wiki Activity

Remove J1939 stub for data calculation

Browse Source 
- To be done separately
This commit is contained in:
Erick
2026-07-13 14:17:12 +02:00
parent 324aa5652c
commit 663d75174e
1 changed files with 0 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/j1939_decoder.py
-24
View File
@@ -64,30 +64,6 @@ def decode_j1939_frames(df: pl.DataFrame) -> pl.DataFrame:
])
).otherwise(None)
b = [pl.col(f"b{i}").fill_null("00").str.to_integer(base=16, strict=False) for i in range(8)]
pgn_j = pl.when(is_j1939).then(pgn).otherwise(None)
data_1 = pl.when(pgn_j.is_in([61444, 65331])).then(1 * 1)
data_2 = pl.when(pgn_j.is_in([61444, 65331])).then(1 * 1)
data_3 = pl.when(pgn_j == 65265).then(1 * 1)
data_4 = pl.when(pgn_j == 65226).then(1 * 1)
data_5 = pl.when(pgn_j == 65271).then(1 * 1)
data_col = pl.coalesce(
pl.when(data_1.is_not_null()).then(pl.lit("VALUE 1")),
pl.when(data_2.is_not_null()).then(pl.lit("VALUE 2")),
pl.when(data_3.is_not_null()).then(pl.lit("VALUE 3")),
pl.when(data_4.is_not_null()).then(pl.lit("VALUE 4")),
pl.when(data_5.is_not_null()).then(pl.lit("VALUE 5")),
)
value_col = pl.coalesce(data_1, data_2, data_3, data_4, data_5)
return df.with_columns([
j1939_meta.alias("j1939_metadata"),
data_col.alias("data"),
value_col.alias("value")
])
if __name__ == "__main__":
parser = argparse.ArgumentParser(description="J1939 decoder")
parser.add_argument("input_parquet", help="Path to the raw .parquet file")