# Safety Consultants Supply — US Directory by State + Specialty (`belcaidsaad/safety-consultants-supply`) Actor US safety consulting supply directory. Two sources: OSHA's 52 state on-site consultation programs (free gov help) + web search across state × specialty (private firms). ~1,500-2,000 unique firms after dedup. For people routing OSHA-cited demand to safety supply. - **URL**: https://apify.com/belcaidsaad/safety-consultants-supply.md - **Developed by:** [Saad Belcaid](https://apify.com/belcaidsaad) (community) - **Categories:** Jobs, Lead generation, SEO tools - **Stats:** 2 total users, 1 monthly users, 100.0% runs succeeded, NaN 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 ## Safety Consultants Supply — Routable Inventory by Incident Type **Built by [Saad Belcaid](https://www.skool.com/@saadbelcaid).** US safety-consulting supply directory **classified by which OSHA incident types each consultant is routable for**. Pairs with `osha-violations-demand` so cited companies route to the right specialist. This is not a contact list. This is **routable supply inventory** — every row tells you which OSHA incidents this consultant can help with, scored 0–3 by fit confidence, with a one-sentence thesis. --- ### What's in the dataset | Field | Why it matters | |---|---| | `matching_incident_types[]` | Maps directly to the demand-side `incident_types` taxonomy. Trench-collapse demand → fall-protection / trench-safety supply. | | `supply_fit_score` | 0 = generalist with no specialist signal, 1 = found in safety-consultant search, 2 = strong match (name/domain hint), 3 = explicit specialist (e.g. "National Trench Safety") | | `supply_thesis` | One-sentence routing justification: who this firm is, why they fit | | `is_state_program` | True for OSHA's 52 free state on-site consultation programs | | `specialties[]` | Broad service categories detected from the search query that surfaced them | ### Two sources 1. **OSHA's State On-Site Consultation Directory** — 30-50 state-level programs (50 states + DC + territories), federally funded, FREE help to small/mid employers. The default routing target for SMB-cited companies who can't afford private consultants. 2. **Startpage web search** — runs queries across **50 states × 14 safety specialties** (~700 queries) to surface private safety consulting firms. Each result classified for incident-type fit. After cross-source dedup: **~1,500-2,500 unique safety consultants**, every one labeled with which OSHA incidents they're routable for. --- ### Incident-type taxonomy (matches demand scraper) The `matching_incident_types[]` field uses the SAME taxonomy as the OSHA demand scraper, so pairing in Connector OS Station is direct: | Incident type | When to route here | |---|---| | `fall` | Fall-protection consultants | | `trench-collapse` | Trench/excavation safety specialists | | `explosion` | Process safety + fire + hazmat | | `combustible-dust` | Dust hazard analysis (NFPA 652/654) | | `confined-space` | Confined-space rescue + permit-required programs | | `chemical-exposure` | HazCom / HAZWOPER consultants | | `machine-guarding` | Machine safety + amputation prevention | | `lockout-tagout` | Energy isolation procedure consultants | | `electrocution` | NFPA 70E / arc flash consultants | | `industrial-hygiene` | CIH-credentialed firms (silica, asbestos, noise) | | `osha-abatement` | OSHA citation defense + remediation | | `repeat-violations` / `willful-violations` | Workplace safety remediation specialists | | `general-osha` | Generalist OSHA compliance consultants | --- ### How fit scoring works | Score | What it means | |---|---| | **3** | Explicit specialist — domain or firm name contains the specialty (e.g. ntsafety.com / National Trench Safety) AND found via a specialty-specific search | | **2** | Strong match — domain or name has incident keywords; firm clearly does this work | | **1** | Found in safety-consultant search but no specialist signal — generalist fit | | **0** | No clear safety-consulting signal (filtered out by default) | Filter `minFitScore: 2` post-scrape if you want only the high-confidence specialists. --- ### Filter recipes #### "Route a trench-collapse OSHA citation" After scrape, filter by: ```` matching\_incident\_types contains "trench-collapse" state matches the demand company's state sort by supply\_fit\_score DESC ``` #### "Route a willful-violations citation" ``` matching\_incident\_types contains "osha-abatement" OR "workplace-safety-remediation" supply\_fit\_score >= 2 ``` #### "Just the free state programs (for SMB demand)" ``` is\_state\_program = true state = demand company's state ```` #### Run-time filter — only emit explicit specialists ```yaml minFitScore: 2 ```` #### Run-time filter — only emit firms that match specific incident types ```yaml matchingIncidentTypes: ["trench-collapse", "combustible-dust", "industrial-hygiene"] ``` *** ### Architecture - Apify Actor, TypeScript, pure HTTP (no Playwright) - Two sources fetched, cross-source domain-deduped - **Cross-query enrichment**: when the same firm is found via multiple specialty searches (e.g. shows up in both "OSHA consultant Texas" AND "industrial hygienist Texas"), the row gets enriched with both incidents → higher fit score - Polite delay between Startpage queries (default 800ms) - Default state coverage = all 50 + DC + territories ### Costs - OSHA: free (US Government) - Startpage: free - Apify compute: ~10–15 min per full run × 256 MB ≈ trivial CU *** ### Connector OS Station integration Pipe both datasets into Station: 1. **Demand**: `osha-violations-demand` → cited companies with incident\_types\[] 2. **Supply**: `safety-consultants-supply` → consultants with matching\_incident\_types\[] Station's I Layer does the routing match. The `supply_thesis` field becomes the operator's CRM note — already pre-written. *** *Built by Saad Belcaid. OSHA data is US Government public record. Web search via Startpage (Google proxy, no API key needed).* # Actor input Schema ## `states` (type: `array`): Restrict to specific US states. Use full names like 'Texas' or 'California'. Empty = all 50 + DC + territories. ## `specialties` (type: `array`): Restrict to specialties. Choose from: osha-general, trench-safety, process-safety, confined-space, combustible-dust, fire-safety, hazmat-safety, machine-guarding, lockout-tagout, fall-protection, electrical-safety, workplace-safety-remediation, industrial-hygiene, ergonomics. Empty = all 14. ## `minFitScore` (type: `integer`): Drop rows below this fit score (0–3). 1 = filter pure noise; 0 = keep everything. ## `matchingIncidentTypes` (type: `array`): If set, keep only rows whose matching\_incident\_types include at least one of these. ## `maxQueries` (type: `integer`): Cap on DuckDuckGo HTML POST queries. State × specialty cross-product is ~1,150 at full breadth. ## `politeDelayMs` (type: `integer`): Throttle between DDG queries and between state-roster fetches. 800ms is comfortable. ## `skipOshaDirectory` (type: `boolean`): Skip the 53 free state on-site consultation programs. ## `skipOtiCenters` (type: `boolean`): Skip the ~26 OSHA-authorized OTI Education Centers (universities/non-profits delivering OSHA 10/30). ## `skipOtiCourseEnrichment` (type: `boolean`): Skip the enrichment pass that adds course\_titles + extra specialties to existing OTI center rows. Does NOT create new rows. ## `skipNioshErc` (type: `boolean`): Skip the 18 NIOSH-funded ERCs (canonical hardcoded list with live URL health check). ## `skipOshaCAS` (type: `boolean`): Skip the CAS probe. Current state: OSHA's contactus/bystate is JS-AJAX hydrated, so probe surfaces as 'blocked' and emits zero rows. No fabricated CAS records. ## `skipDdgWebSearch` (type: `boolean`): Skip the web-search wide-net source. Use when DDG is blocked from the runtime and you want the state-roster spine only. ## `skipStateRosters` (type: `boolean`): Skip the per-state staff/team roster crawl. ## `skipSamGov` (type: `boolean`): Skip the SAM.gov federally-registered EHS/safety consulting firm source. Requires SAM\_GOV\_API\_KEY environment variable. Reports skipped\_missing\_api\_key if absent. ## `skipUsaSpending` (type: `boolean`): Skip the USA Spending federal contract recipients source. Public, no API key. Primary volume source for private safety/EHS consulting firms. ## Actor input object example ```json { "states": [], "specialties": [], "minFitScore": 1, "matchingIncidentTypes": [], "maxQueries": 1200, "politeDelayMs": 800, "skipOshaDirectory": false, "skipOtiCenters": false, "skipOtiCourseEnrichment": false, "skipNioshErc": false, "skipOshaCAS": false, "skipDdgWebSearch": false, "skipStateRosters": false, "skipSamGov": false, "skipUsaSpending": false } ``` # 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("belcaidsaad/safety-consultants-supply").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("belcaidsaad/safety-consultants-supply").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 belcaidsaad/safety-consultants-supply --silent --output-dataset ``` ## MCP server setup ```json { "mcpServers": { "apify": { "command": "npx", "args": [ "mcp-remote", "https://mcp.apify.com/?tools=belcaidsaad/safety-consultants-supply", "--header", "Authorization: Bearer " ] } } } ``` ## OpenAPI specification ```json { "openapi": "3.0.1", "info": { "title": "Safety Consultants Supply — US Directory by State + Specialty", "description": "US safety consulting supply directory. Two sources: OSHA's 52 state on-site consultation programs (free gov help) + web search across state × specialty (private firms). ~1,500-2,000 unique firms after dedup. For people routing OSHA-cited demand to safety supply.", "version": "1.0", "x-build-id": "P532qngReBG2Pj0pf" }, "servers": [ { "url": "https://api.apify.com/v2" } ], "paths": { "/acts/belcaidsaad~safety-consultants-supply/run-sync-get-dataset-items": { "post": { "operationId": "run-sync-get-dataset-items-belcaidsaad-safety-consultants-supply", "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/belcaidsaad~safety-consultants-supply/runs": { "post": { "operationId": "runs-sync-belcaidsaad-safety-consultants-supply", "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/belcaidsaad~safety-consultants-supply/run-sync": { "post": { "operationId": "run-sync-belcaidsaad-safety-consultants-supply", "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": { "states": { "title": "States (full names)", "type": "array", "description": "Restrict to specific US states. Use full names like 'Texas' or 'California'. Empty = all 50 + DC + territories.", "items": { "type": "string" }, "default": [] }, "specialties": { "title": "Specialties", "type": "array", "description": "Restrict to specialties. Choose from: osha-general, trench-safety, process-safety, confined-space, combustible-dust, fire-safety, hazmat-safety, machine-guarding, lockout-tagout, fall-protection, electrical-safety, workplace-safety-remediation, industrial-hygiene, ergonomics. Empty = all 14.", "items": { "type": "string" }, "default": [] }, "minFitScore": { "title": "Minimum Fit Score", "minimum": 0, "maximum": 3, "type": "integer", "description": "Drop rows below this fit score (0–3). 1 = filter pure noise; 0 = keep everything.", "default": 1 }, "matchingIncidentTypes": { "title": "Filter to matching incident types", "type": "array", "description": "If set, keep only rows whose matching_incident_types include at least one of these.", "items": { "type": "string" }, "default": [] }, "maxQueries": { "title": "Maximum DDG Web Search Queries", "minimum": 10, "maximum": 5000, "type": "integer", "description": "Cap on DuckDuckGo HTML POST queries. State × specialty cross-product is ~1,150 at full breadth.", "default": 1200 }, "politeDelayMs": { "title": "Polite Delay Between Requests (ms)", "minimum": 200, "maximum": 5000, "type": "integer", "description": "Throttle between DDG queries and between state-roster fetches. 800ms is comfortable.", "default": 800 }, "skipOshaDirectory": { "title": "Skip OSHA State Consultation Directory", "type": "boolean", "description": "Skip the 53 free state on-site consultation programs.", "default": false }, "skipOtiCenters": { "title": "Skip OSHA OTI Education Centers", "type": "boolean", "description": "Skip the ~26 OSHA-authorized OTI Education Centers (universities/non-profits delivering OSHA 10/30).", "default": false }, "skipOtiCourseEnrichment": { "title": "Skip OTI Course Enrichment", "type": "boolean", "description": "Skip the enrichment pass that adds course_titles + extra specialties to existing OTI center rows. Does NOT create new rows.", "default": false }, "skipNioshErc": { "title": "Skip NIOSH Education and Research Centers", "type": "boolean", "description": "Skip the 18 NIOSH-funded ERCs (canonical hardcoded list with live URL health check).", "default": false }, "skipOshaCAS": { "title": "Skip OSHA Compliance Assistance Specialists probe", "type": "boolean", "description": "Skip the CAS probe. Current state: OSHA's contactus/bystate is JS-AJAX hydrated, so probe surfaces as 'blocked' and emits zero rows. No fabricated CAS records.", "default": false }, "skipDdgWebSearch": { "title": "Skip DuckDuckGo Web Search", "type": "boolean", "description": "Skip the web-search wide-net source. Use when DDG is blocked from the runtime and you want the state-roster spine only.", "default": false }, "skipStateRosters": { "title": "Skip State-Level Consultation Rosters", "type": "boolean", "description": "Skip the per-state staff/team roster crawl.", "default": false }, "skipSamGov": { "title": "Skip SAM.gov Entity Source", "type": "boolean", "description": "Skip the SAM.gov federally-registered EHS/safety consulting firm source. Requires SAM_GOV_API_KEY environment variable. Reports skipped_missing_api_key if absent.", "default": false }, "skipUsaSpending": { "title": "Skip USA Spending Recipients Source", "type": "boolean", "description": "Skip the USA Spending federal contract recipients source. Public, no API key. Primary volume source for private safety/EHS consulting firms.", "default": false } } }, "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 } } } } } } } } } } ```