1from apify_client import ApifyClient
2
3
4
5client = ApifyClient("<YOUR_API_TOKEN>")
6
7
8run_input = { "recordInput": {
9 "mode": "inline",
10 "records": [
11 {
12 "schemaVersion": "1.0",
13 "recordType": "secMarketStructureObservation",
14 "recordId": "s18-1",
15 "parser": { "name": "sec-market-structure-data-normalizer" },
16 "time": { "eventAt": "2026-07-01" },
17 "data": {
18 "securityIdentifiers": [{
19 "kind": "cusip",
20 "value": "037833100",
21 }],
22 "metricType": "ftdQuantity",
23 "value": "10",
24 "unit": "shares",
25 "exchange": "NYSE",
26 "bucket": None,
27 "methodologyVersion": "m1",
28 "evidence": ["ev-s18-1"],
29 },
30 },
31 {
32 "schemaVersion": "1.0",
33 "recordType": "secMarketStructureObservation",
34 "recordId": "s18-2",
35 "parser": { "name": "sec-market-structure-data-normalizer" },
36 "time": { "eventAt": "2026-07-15" },
37 "data": {
38 "securityIdentifiers": [{
39 "kind": "cusip",
40 "value": "037833100",
41 }],
42 "metricType": "ftdQuantity",
43 "value": "20",
44 "unit": "shares",
45 "exchange": "NYSE",
46 "bucket": None,
47 "methodologyVersion": "m1",
48 "evidence": ["ev-s18-2"],
49 },
50 },
51 ],
52 } }
53
54
55run = client.actor("bb-tradetec/sec-market-integrity-aggregator").call(run_input=run_input)
56
57
58print(f"💾 Check your data here: https://console.apify.com/storage/datasets/{run.default_dataset_id}")
59for item in client.dataset(run.default_dataset_id).iterate_items():
60 print(item)
61
62