|
import os |
|
import sys |
|
import csv |
|
import json |
|
import networkx as nx |
|
from collections import defaultdict |
|
|
|
import matplotlib |
|
import matplotlib.pyplot as plt |
|
import warnings |
|
|
|
warnings.filterwarnings('ignore', category=matplotlib.cbook.deprecation.MatplotlibDeprecationWarning) |
|
|
|
|
|
def load_alerts(_conf_json): |
|
_g = nx.DiGraph() |
|
_bank_accts = defaultdict(list) |
|
|
|
with open(_conf_json, "r") as rf: |
|
conf = json.load(rf) |
|
|
|
data_dir = os.path.join(conf["output"]["directory"], conf["general"]["simulation_name"]) |
|
acct_csv = os.path.join(data_dir, conf["output"]["alert_members"]) |
|
tx_csv = os.path.join(data_dir, conf["output"]["alert_transactions"]) |
|
|
|
input_dir = conf["input"]["directory"] |
|
schema_json = os.path.join(input_dir, conf["input"]["schema"]) |
|
with open(schema_json, "r") as rf: |
|
schema = json.load(rf) |
|
|
|
acct_idx = None |
|
bank_idx = None |
|
orig_idx = None |
|
bene_idx = None |
|
amt_idx = None |
|
date_idx = None |
|
for i, col in enumerate(schema["alert_member"]): |
|
if col.get("dataType") == "account_id": |
|
acct_idx = i |
|
elif col.get("dataType") == "bank_id": |
|
bank_idx = i |
|
for i, col in enumerate(schema["alert_tx"]): |
|
if col.get("dataType") == "orig_id": |
|
orig_idx = i |
|
elif col.get("dataType") == "dest_id": |
|
bene_idx = i |
|
elif col.get("dataType") == "amount": |
|
amt_idx = i |
|
elif col.get("dataType") == "timestamp": |
|
date_idx = i |
|
|
|
with open(acct_csv, "r") as rf: |
|
reader = csv.reader(rf) |
|
next(reader) |
|
for row in reader: |
|
acct_id = row[acct_idx] |
|
bank_id = row[bank_idx] |
|
_g.add_node(acct_id, bank_id=bank_id) |
|
_bank_accts[bank_id].append(acct_id) |
|
|
|
with open(tx_csv, "r") as rf: |
|
reader = csv.reader(rf) |
|
next(reader) |
|
for row in reader: |
|
orig_id = row[orig_idx] |
|
bene_id = row[bene_idx] |
|
amount = row[amt_idx] |
|
date = row[date_idx].split("T")[0] |
|
label = amount + "\n" + date |
|
_g.add_edge(orig_id, bene_id, amount=amount, date=date, label=label) |
|
|
|
return _g, _bank_accts |
|
|
|
|
|
def plot_alerts(_g, _bank_accts, _output_png): |
|
bank_ids = _bank_accts.keys() |
|
cmap = plt.get_cmap("tab10") |
|
pos = nx.nx_agraph.graphviz_layout(_g) |
|
|
|
plt.figure(figsize=(12.0, 8.0)) |
|
plt.axis('off') |
|
|
|
for i, bank_id in enumerate(bank_ids): |
|
color = cmap(i) |
|
members = _bank_accts[bank_id] |
|
nx.draw_networkx_nodes(_g, pos, members, node_size=300, node_color=color, label=bank_id) |
|
nx.draw_networkx_labels(_g, pos, {n: n for n in members}, font_size=10) |
|
|
|
edge_labels = nx.get_edge_attributes(_g, "label") |
|
nx.draw_networkx_edges(_g, pos) |
|
nx.draw_networkx_edge_labels(_g, pos, edge_labels, font_size=6) |
|
|
|
plt.legend(numpoints=1) |
|
plt.subplots_adjust(left=0, right=1, bottom=0, top=1) |
|
plt.savefig(_output_png, dpi=120) |
|
|
|
|
|
if __name__ == "__main__": |
|
argv = sys.argv |
|
|
|
if len(argv) < 3: |
|
print("Usage: python3 %s [ConfJSON] [OutputPNG]" % argv[0]) |
|
exit(1) |
|
|
|
conf_json = argv[1] |
|
output_png = argv[2] |
|
g, bank_accts = load_alerts(conf_json) |
|
plot_alerts(g, bank_accts, output_png) |
|
|
