1from apify_client import ApifyClient
2
3
4
5client = ApifyClient("<YOUR_API_TOKEN>")
6
7
8run_input = {
9 "inlineSources": [
10 {
11 "name": "crm-export",
12 "format": "csv",
13 "text": """email,name,country,plan,signup
14anna@example.com,Anna Smith,US,pro,2024-01-15
15ben@example.com,Ben Jones,UK,free,2024-02-03
16carla@example.com,Carla Diaz,US,pro,2024-02-20
17dev@example.com,Dev Patel,IN,free,2024-03-01
18""",
19 },
20 {
21 "name": "newsletter-list",
22 "format": "csv",
23 "text": """email,name,country,plan,signup,company
24ANNA@example.com,Anna Smith,US,pro,2024-01-15,Acme
25carla@example.com,Carla Diaz,US,enterprise,2024-04-10,Globex
26elena@example.com,Elena Rossi,IT,pro,2024-04-12,Initech
27frank@example.com,Frank Moore,US,free,2024-05-02,Umbrella
28""",
29 },
30 ],
31 "sourceField": "source",
32 "dedupeMode": "keys",
33 "dedupeKeys": ["email"],
34 "dedupeKeep": "first",
35 "dedupeCaseInsensitive": True,
36 "filters": [{
37 "field": "plan",
38 "op": "notEquals",
39 "value": "free",
40 }],
41 "sortBy": ["signup:desc"],
42 "exports": [
43 "csv",
44 "xlsx",
45 ],
46}
47
48
49run = client.actor("data-done-right/merge-datasets").call(run_input=run_input)
50
51
52print(f"💾 Check your data here: https://console.apify.com/storage/datasets/{run.default_dataset_id}")
53for item in client.dataset(run.default_dataset_id).iterate_items():
54 print(item)
55
56