Parse, Clean, Aggregate Crypto Logs | Dataford Interview Questions

Write a Python script to parse, clean, and aggregate a mock stream of cryptocurrency transaction logs.

Each log is a pipe-delimited string with the format timestamp|transaction_id|asset|side|amount|price|status. Implement aggregate_transactions(logs) to ignore malformed records, normalize asset and status casing, accept only positive numeric amounts and prices with buy or sell sides, include only completed transactions, and ignore duplicate valid transaction IDs. Return a dictionary keyed by uppercase asset, with volume and notional totals rounded to 8 decimal places. Output keys must be inserted in sorted asset order.

Constraints

1 <= len(logs) <= 5000
Each log is a string with at most 7 pipe-delimited fields
Transaction IDs are arbitrary nonempty strings
Amounts and prices must be finite positive decimal values
Only records with status completed and side buy or sell are aggregated
Duplicate valid transaction IDs are ignored after their first occurrence

Function Signature

def aggregate_transactions(logs):

Your question is Parse, Clean, Aggregate Crypto Logs. Start with the requirements in the Question tab.

Run and submit as often as you like. When you're ready, talk me through your approach or go straight to the code.

Problem

Write a Python script to parse, clean, and aggregate a mock stream of cryptocurrency transaction logs.

Constraints

1 <= len(logs) <= 5000
Each log is a string with at most 7 pipe-delimited fields
Transaction IDs are arbitrary nonempty strings
Amounts and prices must be finite positive decimal values
Only records with status completed and side buy or sell are aggregated
Duplicate valid transaction IDs are ignored after their first occurrence

Function Signature

def aggregate_transactions(logs):

Your question is Parse, Clean, Aggregate Crypto Logs. Start with the requirements in the Question tab.

Run and submit as often as you like. When you're ready, talk me through your approach or go straight to the code.