# Product Recall Aggregator — FDA, NHTSA & CPSC (`foo121/recall-aggregator`) Actor Unified US product-recall feed across FDA (food, drug, device), NHTSA (vehicles) and CPSC (consumer products), normalized to one schema. For compliance, insurance, legal and retail monitoring. Pay per result. - **URL**: https://apify.com/foo121/recall-aggregator.md - **Developed by:** [ziv shay](https://apify.com/foo121) (community) - **Categories:** Business - **Stats:** 2 total users, 1 monthly users, 100.0% runs succeeded, 0 bookmarks - **User rating**: No ratings yet ## Pricing Pay per usage This Actor is paid per platform usage. The Actor is free to use, and you only pay for the Apify platform usage, which gets cheaper the higher subscription plan you have. Learn more: https://docs.apify.com/platform/actors/running/actors-in-store#pay-per-usage ## What's an Apify Actor? Actors are a software tools running on the Apify platform, for all kinds of web data extraction and automation use cases. In Batch mode, an Actor accepts a well-defined JSON input, performs an action which can take anything from a few seconds to a few hours, and optionally produces a well-defined JSON output, datasets with results, or files in key-value store. In Standby mode, an Actor provides a web server which can be used as a website, API, or an MCP server. Actors are written with capital "A". ## How to integrate an Actor? If asked about integration, you help developers integrate Actors into their projects. You adapt to their stack and deliver integrations that are safe, well-documented, and production-ready. The best way to integrate Actors is as follows. In JavaScript/TypeScript projects, use official [JavaScript/TypeScript client](https://docs.apify.com/api/client/js.md): ```bash npm install apify-client ``` In Python projects, use official [Python client library](https://docs.apify.com/api/client/python.md): ```bash pip install apify-client ``` In shell scripts, use [Apify CLI](https://docs.apify.com/cli/docs.md): ````bash # MacOS / Linux curl -fsSL https://apify.com/install-cli.sh | bash # Windows irm https://apify.com/install-cli.ps1 | iex ```bash In AI frameworks, you might use the [Apify MCP server](https://docs.apify.com/platform/integrations/mcp.md). If your project is in a different language, use the [REST API](https://docs.apify.com/api/v2.md). For usage examples, see the [API](#api) section below. For more details, see Apify documentation as [Markdown index](https://docs.apify.com/llms.txt) and [Markdown full-text](https://docs.apify.com/llms-full.txt). # README ## Product Recall Aggregator — FDA, NHTSA & CPSC **Product recall data from all three official US agencies in one normalized feed — an FDA recall scraper, NHTSA vehicle recalls, and CPSC consumer-product recalls merged into a single recall API feed.** Built for compliance, insurance, legal, and retail/QA monitoring teams who need to watch every US product recall without stitching together three different government feeds. Each agency publishes its own official data in its own shape — this actor pulls FDA (openFDA food/drug/device), NHTSA (vehicles), and CPSC (consumer products), then normalizes and dedupes them into one schema. No API key required; it's the official public recall data, just unified. If you monitor recalls today you're probably querying openFDA, NHTSA, and CPSC separately and reconciling fields by hand. This does CPSC NHTSA recalls plus FDA in a single run, ready to drop into a dataset or alert pipeline. ### What you get | Field | Description | | --- | --- | | `agency` | Source agency: `FDA`, `NHTSA`, or `CPSC` | | `category` | Recall category: `food`, `drug`, `device`, `vehicle`, or `product` | | `title` | Recall title / product description | | `brand` | Brand or manufacturer name | | `hazard` | The hazard or reason for the recall | | `date` | Recall date (ISO 8601) | | `url` | Link to the official recall notice | | `remedy` | Recommended remedy / corrective action | ### Input | Field | Type | Default | Description | | --- | --- | --- | --- | | `categories` | array | `["all"]` | Which categories to pull. Use `"all"` or a subset of `food`, `drug`, `device`, `vehicle`, `product` | | `daysBack` | integer | `90` | Only return recalls issued within the last N days | | `maxItems` | integer | `500` | Maximum number of recalls to return | #### Example input ```json { "categories": ["food", "drug", "vehicle"], "daysBack": 30, "maxItems": 200 } ```` ### Example run output ```json { "agency": "FDA", "category": "food", "title": "Listeria Risk in Pre-Cut Cantaloupe Trays", "brand": "FreshFields Produce", "hazard": "Potential Listeria monocytogenes contamination", "date": "2026-06-12", "url": "https://www.fda.gov/safety/recalls-market-withdrawals-safety-alerts/freshfields-cantaloupe", "remedy": "Do not consume. Return to place of purchase for a full refund." } ``` ### Use cases - **Compliance teams** monitoring whether any recalled product touches their supply chain across food, drug, device, and consumer goods. - **Insurance underwriters and claims teams** tracking vehicle and product recalls tied to liability exposure. - **Legal / litigation researchers** building recall timelines for product-liability matters. - **Retail and QA monitoring teams** pulling a single daily feed of all US recalls instead of three separate agency checks. ### Why this vs single-agency feeds The wedge is the **unified schema**. Most tools and feeds give you one agency at a time, in different shapes — openFDA looks nothing like the NHTSA recalls API, which looks nothing like CPSC. This actor merges FDA + NHTSA + CPSC into one normalized, deduped dataset so you monitor all US recalls in a single run. It's the official public recall data — the value is that it's consolidated, not exclusive. ### Pricing Pay per result — you're billed only for the recall records returned, no subscription. ### Keywords product recall data, FDA recall scraper, recall API feed, CPSC NHTSA recalls, FDA NHTSA CPSC recalls, openFDA recall scraper, vehicle recall data, consumer product recall feed, food recall API, drug recall data # Actor input Schema ## `categories` (type: `array`): Which recall categories to fetch. Use "all" for everything. Subset of: food, drug, device, vehicle, product. ## `daysBack` (type: `integer`): Only include recalls reported within this many days of today. ## `maxItems` (type: `integer`): Maximum number of normalized recall records to output. ## Actor input object example ```json { "categories": [ "all" ], "daysBack": 90, "maxItems": 500 } ``` # API You can run this Actor programmatically using our API. Below are code examples in JavaScript, Python, and CLI, as well as the OpenAPI specification and MCP server setup. ## JavaScript example ```javascript import { ApifyClient } from 'apify-client'; // Initialize the ApifyClient with your Apify API token // Replace the '' with your token const client = new ApifyClient({ token: '', }); // Prepare Actor input const input = {}; // Run the Actor and wait for it to finish const run = await client.actor("foo121/recall-aggregator").call(input); // Fetch and print Actor results from the run's dataset (if any) console.log('Results from dataset'); console.log(`💾 Check your data here: https://console.apify.com/storage/datasets/${run.defaultDatasetId}`); const { items } = await client.dataset(run.defaultDatasetId).listItems(); items.forEach((item) => { console.dir(item); }); // 📚 Want to learn more 📖? Go to → https://docs.apify.com/api/client/js/docs ``` ## Python example ```python from apify_client import ApifyClient # Initialize the ApifyClient with your Apify API token # Replace '' with your token. client = ApifyClient("") # Prepare the Actor input run_input = {} # Run the Actor and wait for it to finish run = client.actor("foo121/recall-aggregator").call(run_input=run_input) # Fetch and print Actor results from the run's dataset (if there are any) print("💾 Check your data here: https://console.apify.com/storage/datasets/" + run["defaultDatasetId"]) for item in client.dataset(run["defaultDatasetId"]).iterate_items(): print(item) # 📚 Want to learn more 📖? Go to → https://docs.apify.com/api/client/python/docs/quick-start ``` ## CLI example ```bash echo '{}' | apify call foo121/recall-aggregator --silent --output-dataset ``` ## MCP server setup ```json { "mcpServers": { "apify": { "command": "npx", "args": [ "mcp-remote", "https://mcp.apify.com/?tools=foo121/recall-aggregator", "--header", "Authorization: Bearer " ] } } } ``` ## OpenAPI specification ```json { "openapi": "3.0.1", "info": { "title": "Product Recall Aggregator — FDA, NHTSA & CPSC", "description": "Unified US product-recall feed across FDA (food, drug, device), NHTSA (vehicles) and CPSC (consumer products), normalized to one schema. For compliance, insurance, legal and retail monitoring. Pay per result.", "version": "1.0", "x-build-id": "jhPVKdMi6L8F5YTp6" }, "servers": [ { "url": "https://api.apify.com/v2" } ], "paths": { "/acts/foo121~recall-aggregator/run-sync-get-dataset-items": { "post": { "operationId": "run-sync-get-dataset-items-foo121-recall-aggregator", "x-openai-isConsequential": false, "summary": "Executes an Actor, waits for its completion, and returns Actor's dataset items in response.", "tags": [ "Run Actor" ], "requestBody": { "required": true, "content": { "application/json": { "schema": { "$ref": "#/components/schemas/inputSchema" } } } }, "parameters": [ { "name": "token", "in": "query", "required": true, "schema": { "type": "string" }, "description": "Enter your Apify token here" } ], "responses": { "200": { "description": "OK" } } } }, "/acts/foo121~recall-aggregator/runs": { "post": { "operationId": "runs-sync-foo121-recall-aggregator", "x-openai-isConsequential": false, "summary": "Executes an Actor and returns information about the initiated run in response.", "tags": [ "Run Actor" ], "requestBody": { "required": true, "content": { "application/json": { "schema": { "$ref": "#/components/schemas/inputSchema" } } } }, "parameters": [ { "name": "token", "in": "query", "required": true, "schema": { "type": "string" }, "description": "Enter your Apify token here" } ], "responses": { "200": { "description": "OK", "content": { "application/json": { "schema": { "$ref": "#/components/schemas/runsResponseSchema" } } } } } } }, "/acts/foo121~recall-aggregator/run-sync": { "post": { "operationId": "run-sync-foo121-recall-aggregator", "x-openai-isConsequential": false, "summary": "Executes an Actor, waits for completion, and returns the OUTPUT from Key-value store in response.", "tags": [ "Run Actor" ], "requestBody": { "required": true, "content": { "application/json": { "schema": { "$ref": "#/components/schemas/inputSchema" } } } }, "parameters": [ { "name": "token", "in": "query", "required": true, "schema": { "type": "string" }, "description": "Enter your Apify token here" } ], "responses": { "200": { "description": "OK" } } } } }, "components": { "schemas": { "inputSchema": { "type": "object", "properties": { "categories": { "title": "Categories", "type": "array", "description": "Which recall categories to fetch. Use \"all\" for everything. Subset of: food, drug, device, vehicle, product.", "items": { "type": "string", "enum": [ "all", "food", "drug", "device", "vehicle", "product" ], "enumTitles": [ "All categories", "Food (FDA)", "Drug (FDA)", "Device (FDA)", "Vehicle (NHTSA)", "Consumer product (CPSC)" ] }, "default": [ "all" ] }, "daysBack": { "title": "Days back", "minimum": 1, "maximum": 3650, "type": "integer", "description": "Only include recalls reported within this many days of today.", "default": 90 }, "maxItems": { "title": "Max items", "minimum": 1, "maximum": 10000, "type": "integer", "description": "Maximum number of normalized recall records to output.", "default": 500 } } }, "runsResponseSchema": { "type": "object", "properties": { "data": { "type": "object", "properties": { "id": { "type": "string" }, "actId": { "type": "string" }, "userId": { "type": "string" }, "startedAt": { "type": "string", "format": "date-time", "example": "2025-01-08T00:00:00.000Z" }, "finishedAt": { "type": "string", "format": "date-time", "example": "2025-01-08T00:00:00.000Z" }, "status": { "type": "string", "example": "READY" }, "meta": { "type": "object", "properties": { "origin": { "type": "string", "example": "API" }, "userAgent": { "type": "string" } } }, "stats": { "type": "object", "properties": { "inputBodyLen": { "type": "integer", "example": 2000 }, "rebootCount": { "type": "integer", "example": 0 }, "restartCount": { "type": "integer", "example": 0 }, "resurrectCount": { "type": "integer", "example": 0 }, "computeUnits": { "type": "integer", "example": 0 } } }, "options": { "type": "object", "properties": { "build": { "type": "string", "example": "latest" }, "timeoutSecs": { "type": "integer", "example": 300 }, "memoryMbytes": { "type": "integer", "example": 1024 }, "diskMbytes": { "type": "integer", "example": 2048 } } }, "buildId": { "type": "string" }, "defaultKeyValueStoreId": { "type": "string" }, "defaultDatasetId": { "type": "string" }, "defaultRequestQueueId": { "type": "string" }, "buildNumber": { "type": "string", "example": "1.0.0" }, "containerUrl": { "type": "string" }, "usage": { "type": "object", "properties": { "ACTOR_COMPUTE_UNITS": { "type": "integer", "example": 0 }, "DATASET_READS": { "type": "integer", "example": 0 }, "DATASET_WRITES": { "type": "integer", "example": 0 }, "KEY_VALUE_STORE_READS": { "type": "integer", "example": 0 }, "KEY_VALUE_STORE_WRITES": { "type": "integer", "example": 1 }, "KEY_VALUE_STORE_LISTS": { "type": "integer", "example": 0 }, "REQUEST_QUEUE_READS": { "type": "integer", "example": 0 }, "REQUEST_QUEUE_WRITES": { "type": "integer", "example": 0 }, "DATA_TRANSFER_INTERNAL_GBYTES": { "type": "integer", "example": 0 }, "DATA_TRANSFER_EXTERNAL_GBYTES": { "type": "integer", "example": 0 }, "PROXY_RESIDENTIAL_TRANSFER_GBYTES": { "type": "integer", "example": 0 }, "PROXY_SERPS": { "type": "integer", "example": 0 } } }, "usageTotalUsd": { "type": "number", "example": 0.00005 }, "usageUsd": { "type": "object", "properties": { "ACTOR_COMPUTE_UNITS": { "type": "integer", "example": 0 }, "DATASET_READS": { "type": "integer", "example": 0 }, "DATASET_WRITES": { "type": "integer", "example": 0 }, "KEY_VALUE_STORE_READS": { "type": "integer", "example": 0 }, "KEY_VALUE_STORE_WRITES": { "type": "number", "example": 0.00005 }, "KEY_VALUE_STORE_LISTS": { "type": "integer", "example": 0 }, "REQUEST_QUEUE_READS": { "type": "integer", "example": 0 }, "REQUEST_QUEUE_WRITES": { "type": "integer", "example": 0 }, "DATA_TRANSFER_INTERNAL_GBYTES": { "type": "integer", "example": 0 }, "DATA_TRANSFER_EXTERNAL_GBYTES": { "type": "integer", "example": 0 }, "PROXY_RESIDENTIAL_TRANSFER_GBYTES": { "type": "integer", "example": 0 }, "PROXY_SERPS": { "type": "integer", "example": 0 } } } } } } } } } } ```