1from apify_client import ApifyClient
2
3
4
5client = ApifyClient("<YOUR_API_TOKEN>")
6
7
8run_input = { "comparisons": [{
9 "id": "synthetic-new-unaligned-source",
10 "domain": "example.invalid",
11 "baselineReports": [{
12 "id": "baseline-receiver-a",
13 "format": "XML",
14 "xml": """<?xml version=\"1.0\" encoding=\"UTF-8\"?>
15<feedback>
16 <report_metadata><org_name>Receiver A</org_name><email>reports@receiver.example</email><report_id>baseline-20260916</report_id><date_range><begin>1789516800</begin><end>1789603199</end></date_range></report_metadata>
17 <policy_published><domain>example.invalid</domain><adkim>r</adkim><aspf>r</aspf><p>none</p></policy_published>
18 <record><row><source_ip>192.0.2.10</source_ip><count>20</count><policy_evaluated><disposition>none</disposition><dkim>pass</dkim><spf>pass</spf></policy_evaluated></row><identifiers><header_from>example.invalid</header_from><envelope_from>example.invalid</envelope_from></identifiers><auth_results><dkim><domain>example.invalid</domain><result>pass</result><selector>mail</selector></dkim><spf><domain>example.invalid</domain><result>pass</result><scope>mfrom</scope></spf></auth_results></record>
19</feedback>""",
20 }],
21 "currentReports": [{
22 "id": "current-receiver-a",
23 "format": "XML",
24 "xml": """<?xml version=\"1.0\" encoding=\"UTF-8\"?>
25<feedback>
26 <report_metadata><org_name>Receiver A</org_name><email>reports@receiver.example</email><report_id>current-20260917</report_id><date_range><begin>1789603200</begin><end>1789689599</end></date_range></report_metadata>
27 <policy_published><domain>example.invalid</domain><adkim>r</adkim><aspf>r</aspf><p>none</p></policy_published>
28 <record><row><source_ip>192.0.2.10</source_ip><count>22</count><policy_evaluated><disposition>none</disposition><dkim>pass</dkim><spf>pass</spf></policy_evaluated></row><identifiers><header_from>example.invalid</header_from><envelope_from>example.invalid</envelope_from></identifiers><auth_results><dkim><domain>example.invalid</domain><result>pass</result><selector>mail</selector></dkim><spf><domain>example.invalid</domain><result>pass</result><scope>mfrom</scope></spf></auth_results></record>
29 <record><row><source_ip>198.51.100.44</source_ip><count>7</count><policy_evaluated><disposition>quarantine</disposition><dkim>fail</dkim><spf>fail</spf></policy_evaluated></row><identifiers><header_from>example.invalid</header_from><envelope_from>mailer.vendor.invalid</envelope_from></identifiers><auth_results><dkim><domain>mailer.vendor.invalid</domain><result>fail</result><selector>outbound</selector></dkim><spf><domain>mailer.vendor.invalid</domain><result>pass</result><scope>mfrom</scope></spf></auth_results></record>
30</feedback>""",
31 }],
32 }] }
33
34
35run = client.actor("ceddl/dmarc-aggregate-drift-monitor").call(run_input=run_input)
36
37
38print(f"💾 Check your data here: https://console.apify.com/storage/datasets/{run.default_dataset_id}")
39for item in client.dataset(run.default_dataset_id).iterate_items():
40 print(item)
41
42