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