1from apify_client import ApifyClient
2
3
4
5client = ApifyClient("<YOUR_API_TOKEN>")
6
7
8run_input = {
9 "schemaVersion": "1.1",
10 "target": "hubspot_v1_1",
11 "mapping": [
12 {
13 "sourceField": "brand_name",
14 "targetField": "name",
15 "transform": "trim",
16 },
17 {
18 "sourceField": "signal_status",
19 "targetField": "signal_status",
20 "transform": "lowercase",
21 },
22 {
23 "sourceField": "score",
24 "targetField": "signal_score",
25 "transform": "number_decimal_2",
26 },
27 {
28 "sourceField": "observed_at",
29 "targetField": "last_observed_at",
30 "transform": "date_yyyy_mm_dd",
31 },
32 ],
33 "rows": [
34 {
35 "signalId": "sig-001",
36 "entityId": "brand-acme",
37 "sourceEvidenceId": "ev-001",
38 "sourceUrl": "https://evidence.example.com/acme/offer",
39 "observedAt": "2026-08-05T10:00:00Z",
40 "values": {
41 "brand_name": " Acme ",
42 "signal_status": "ACTIVE",
43 "score": 82.5,
44 },
45 },
46 {
47 "signalId": "sig-002",
48 "entityId": "brand-acme",
49 "sourceEvidenceId": "ev-002",
50 "sourceUrl": "https://evidence.example.com/acme/news",
51 "observedAt": "2026-08-05T11:00:00Z",
52 "values": {
53 "brand_name": "Acme",
54 "signal_status": "ACTIVE",
55 "score": 82.5,
56 },
57 },
58 ],
59}
60
61
62run = client.actor("zinin/us-brand-signal-crm-field-mapper").call(run_input=run_input)
63
64
65print(f"💾 Check your data here: https://console.apify.com/storage/datasets/{run.default_dataset_id}")
66for item in client.dataset(run.default_dataset_id).iterate_items():
67 print(item)
68
69