Compare commits
7 Commits
17340746ce
..
v0.0.2
| Author | SHA1 | Date | |
|---|---|---|---|
| 8a3fc81d12 | |||
| db7e5eb40e | |||
| 8ccb97afae | |||
| 13d91d566b | |||
| 118f1567a2 | |||
| cbba800536 | |||
| ad8334c915 |
@@ -1,3 +1,7 @@
|
|||||||
|
# File: decoder.py
|
||||||
|
# Copyright (C) 2026 Erick Ahmed
|
||||||
|
# SPDX-License-Identifier: AGPL-3.0-or-later
|
||||||
|
|
||||||
import argparse
|
import argparse
|
||||||
import polars as pl
|
import polars as pl
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,3 @@
|
|||||||
|
# File: main.py
|
||||||
|
# Copyright (C) 2026 Erick Ahmed
|
||||||
|
# SPDX-License-Identifier: AGPL-3.0-or-later
|
||||||
|
|||||||
@@ -1,3 +1,7 @@
|
|||||||
|
# File: parser.py
|
||||||
|
# Copyright (C) 2026 Erick Ahmed
|
||||||
|
# SPDX-License-Identifier: AGPL-3.0-or-later
|
||||||
|
|
||||||
import re
|
import re
|
||||||
import csv
|
import csv
|
||||||
import polars as pl
|
import polars as pl
|
||||||
|
|||||||
+84
-15
@@ -1,3 +1,7 @@
|
|||||||
|
# File: frequency.py
|
||||||
|
# Copyright (C) 2026 Erick Ahmed
|
||||||
|
# SPDX-License-Identifier: AGPL-3.0-or-later
|
||||||
|
|
||||||
import argparse
|
import argparse
|
||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
import pandas as pd
|
import pandas as pd
|
||||||
@@ -19,29 +23,94 @@ def plot_freq(stats_df: pd.DataFrame, title: str) -> go.Figure:
|
|||||||
stats_df, y='Identifier', x='Count', orientation='h', title=title, log_x=True,
|
stats_df, y='Identifier', x='Count', orientation='h', title=title, log_x=True,
|
||||||
labels={'Identifier': 'PGN / CAN ID', 'Count': 'Message Count'},
|
labels={'Identifier': 'PGN / CAN ID', 'Count': 'Message Count'},
|
||||||
color='Count', color_continuous_scale='Turbo',
|
color='Count', color_continuous_scale='Turbo',
|
||||||
hover_data={'Percentage': ':.2f', 'Count': True, 'Identifier': True}
|
range_color=(stats_df['Count'].min(), stats_df['Count'].max()),
|
||||||
|
hover_data={'Percentage': ':.2f', 'Count': ':,', 'Identifier': True}
|
||||||
)
|
)
|
||||||
fig.update_layout(
|
fig.update_layout(
|
||||||
height=max(600, len(stats_df) * 18), width=1000,
|
height=max(600, len(stats_df) * 18),
|
||||||
xaxis_title='Total Message Count (Log Scale)', yaxis_title='PGN or CAN ID',
|
autosize=True,
|
||||||
yaxis={'categoryorder': 'total ascending'},
|
template='plotly_white',
|
||||||
plot_bgcolor='rgba(0,0,0,0)', paper_bgcolor='white',
|
xaxis=dict(
|
||||||
font=dict(family="Segoe UI, Arial, sans-serif", size=12),
|
title=dict(text="Message count [log scale]", font=dict(size=13, color="#1a1a1a")),
|
||||||
hoverlabel=dict(bgcolor="white", font_size=13, font_family="Segoe UI"),
|
side="top",
|
||||||
margin=dict(l=250, r=50, t=80, b=50),
|
dtick=1,
|
||||||
title=dict(font=dict(size=20), x=0.5)
|
showgrid=False,
|
||||||
|
linecolor="#bdbdbd",
|
||||||
|
tickfont=dict(size=12, color="#2a2a2a"),
|
||||||
|
ticks="outside",
|
||||||
|
ticklen=4,
|
||||||
|
tickcolor="#cccccc",
|
||||||
|
),
|
||||||
|
yaxis=dict(
|
||||||
|
title=dict(text="PGN or CAN ID", font=dict(size=13, color="#1a1a1a")),
|
||||||
|
#autorange="",
|
||||||
|
showgrid=False,
|
||||||
|
linecolor="#bdbdbd",
|
||||||
|
tickfont=dict(size=12, color="#2a2a2a"),
|
||||||
|
ticks="outside",
|
||||||
|
ticklen=4,
|
||||||
|
tickcolor="#cccccc",
|
||||||
|
automargin=True,
|
||||||
|
),
|
||||||
|
font=dict(family="Segoe UI, Arial, sans-serif", size=12, color='#2a2a2a'),
|
||||||
|
hoverlabel=dict(bgcolor="white", font_size=13, font_family="Segoe UI",
|
||||||
|
bordercolor='#cccccc'),
|
||||||
|
margin=dict(l=200, r=40, t=120, b=60),
|
||||||
|
bargap=0.35,
|
||||||
|
coloraxis_colorbar=dict(
|
||||||
|
title=dict(text='Message Count', side='top'),
|
||||||
|
orientation='h',
|
||||||
|
thickness=15,
|
||||||
|
len=0.35,
|
||||||
|
x=1.0,
|
||||||
|
xanchor='right',
|
||||||
|
y=1.02,
|
||||||
|
yanchor='bottom',
|
||||||
|
tickformat=',',
|
||||||
|
outlinecolor='#cccccc',
|
||||||
|
outlinewidth=0.5
|
||||||
|
),
|
||||||
|
title=dict(font=dict(size=20, color='#1a1a1a'), x=0.5, xanchor='center',
|
||||||
|
pad=dict(b=20))
|
||||||
|
)
|
||||||
|
fig.update_xaxes(
|
||||||
|
showgrid=True, gridwidth=0.5, gridcolor='#e8e8e8',
|
||||||
|
zeroline=False, linecolor='#bdbdbd', mirror=False,
|
||||||
|
tickformat=',',
|
||||||
|
minor=dict(showgrid=True, gridcolor='#f4f4f4', gridwidth=0.5)
|
||||||
|
)
|
||||||
|
fig.update_yaxes(
|
||||||
|
showgrid=False, zeroline=False, linecolor='#bdbdbd',
|
||||||
|
ticks='outside', ticklen=4, tickcolor='#cccccc',
|
||||||
|
automargin=True
|
||||||
|
)
|
||||||
|
fig.update_traces(
|
||||||
|
hovertemplate="<b>%{y}</b><br>Count: %{x:,}<br>Share: %{customdata[0]}%<extra></extra>",
|
||||||
|
marker_line_width=0,
|
||||||
|
texttemplate='%{x:,}',
|
||||||
|
textposition='outside',
|
||||||
|
textfont=dict(size=10, color='#666666'),
|
||||||
|
cliponaxis=False,
|
||||||
|
selected=dict(marker=dict(opacity=0.6)),
|
||||||
|
unselected=dict(marker=dict(opacity=0.2))
|
||||||
)
|
)
|
||||||
fig.update_traces(hovertemplate="<b>%{y}</b><br>Count: %{x:,}<br>Share: %{customdata[0]}%<extra></extra>")
|
|
||||||
return fig
|
return fig
|
||||||
|
|
||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
parser = argparse.ArgumentParser(description="Analyze CAN bus frequency.")
|
parser = argparse.ArgumentParser(description="Analyze CAN bus message frequency")
|
||||||
parser.add_argument("-i", "--input", type=Path, required=True)
|
parser.add_argument("input", type=Path, help="Path to the input CAN log file")
|
||||||
parser.add_argument("-o", "--output", type=Path, default=Path("freq_report.html"))
|
parser.add_argument("output", type=Path, nargs="?", default=Path("freq_report.html"), help="Path to the output HTML report")
|
||||||
parser.add_argument("-t", "--title", type=str, default="CAN Bus Message Frequency")
|
parser.add_argument("title", nargs="?", default="CAN Bus Message Frequency", help="Title for the HTML report")
|
||||||
args = parser.parse_args()
|
args = parser.parse_args()
|
||||||
|
|
||||||
df = load_data(args.input)
|
df = load_data(args.input)
|
||||||
stats = calc_freq(df)
|
stats = calc_freq(df)
|
||||||
fig = plot_freq(stats, title=args.title)
|
fig = plot_freq(stats, title=args.title)
|
||||||
fig.write_html(str(args.output), include_plotlyjs='cdn')
|
config = {
|
||||||
|
'responsive': True,
|
||||||
|
'displaylogo': False,
|
||||||
|
'scrollZoom': True,
|
||||||
|
'modeBarButtonsToAdd': ['toggleSpikelines'],
|
||||||
|
'toImageButtonOptions': {'format': 'png', 'scale': 2}
|
||||||
|
}
|
||||||
|
fig.write_html(str(args.output), include_plotlyjs='cdn', config=config)
|
||||||
|
|||||||
@@ -0,0 +1,27 @@
|
|||||||
|
# File: extractor.py
|
||||||
|
# Copyright (C) 2026 Erick Ahmed
|
||||||
|
# SPDX-License-Identifier: AGPL-3.0-or-later
|
||||||
|
|
||||||
|
import json
|
||||||
|
from pathlib import Path
|
||||||
|
import pandas as pd
|
||||||
|
|
||||||
|
def extract_id(row: pd.Series) -> str:
|
||||||
|
"""Extracts PGN from metadata or falls back to CAN ID."""
|
||||||
|
meta = row.get('j1939_metadata')
|
||||||
|
if pd.isna(meta):
|
||||||
|
return f"ID: {row['ID']}"
|
||||||
|
if isinstance(meta, str):
|
||||||
|
try:
|
||||||
|
meta = json.loads(meta)
|
||||||
|
except json.JSONDecodeError:
|
||||||
|
return f"ID: {row['ID']}"
|
||||||
|
if isinstance(meta, dict) and 'PGN' in meta:
|
||||||
|
return f"PGN: {meta['PGN']}"
|
||||||
|
return f"ID: {row['ID']}"
|
||||||
|
|
||||||
|
def load_data(file_path: Path) -> pd.DataFrame:
|
||||||
|
"""Loads Parquet file and adds an Identifier column."""
|
||||||
|
df = pd.read_parquet(file_path)
|
||||||
|
df['Identifier'] = df.apply(extract_id, axis=1)
|
||||||
|
return df
|
||||||
Reference in New Issue
Block a user