# Shopify Catalog and Price Change Monitor (`orbiscribe/shopify-catalog-price-monitor`) Actor Extract public Shopify product catalogs from store domains and monitor product, variant, price, compare-at price, image, and availability changes. - **URL**: https://apify.com/orbiscribe/shopify-catalog-price-monitor.md - **Developed by:** [Orbiscribe Labs](https://apify.com/orbiscribe) (community) - **Categories:** E-commerce, Automation, Business - **Stats:** 2 total users, 0 monthly users, 100.0% runs succeeded, NaN bookmarks - **User rating**: No ratings yet ## Pricing $2.00 / 1,000 shopify product records This Actor is paid per event. You are not charged for the Apify platform usage, but only a fixed price for specific events. Learn more: https://docs.apify.com/platform/actors/running/actors-in-store#pay-per-event ## 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 ## Shopify Catalog and Price Change Monitor Extract public Shopify product catalogs from store domains and monitor product, variant, price, compare-at price, image, and availability changes. This Actor is for ecommerce operators, agencies, resellers, product researchers, and price-monitoring workflows that need a clean product dataset from public Shopify stores. It uses user-supplied store domains and public Shopify `products.json` catalog endpoints. It does not log in, bypass paywalls, scrape private accounts, or target major marketplaces such as Amazon or Walmart. ### Run This First Paste one public Shopify store and keep the first run small: ```json { "storeDomains": ["allbirds.com"], "maxProductsPerStore": 25, "includeVariants": true, "includeImages": true, "compareToPreviousRun": true, "snapshotStoreName": "shopify-competitor-watch", "dryRun": false } ```` Look first at `productTitle`, `variants`, `minPrice`, `maxPrice`, `newProduct`, `changeTypes`, and `BUYER_BRIEF`. A practical workflow recipe is in `docs/workflow-recipes/shopify-competitor-catalog-watch.md` in the GitHub repository. ### What You Get Each result is one Shopify product record: - store domain - product title, handle, URL, vendor, type, tags - min and max variant price - variant count and available variant count - variant SKUs, prices, compare-at prices, and availability - product image URLs - new product, price changed, and availability changed flags - source URL and compliance notes The run also writes key-value outputs: - `RUN_SUMMARY`: counts, status, and errors - `PRODUCT_EXPORT`: all emitted product records - `BUYER_BRIEF`: a short Markdown brief of products to review - `SLACK_ALERTS`: compact alert objects for webhook or chat workflows ### Input Run with defaults for a demo. For live results, set `dryRun` to `false`. ```json { "storeDomains": ["allbirds.com"], "maxProductsPerStore": 100, "includeVariants": true, "includeImages": true, "compareToPreviousRun": true, "dryRun": false } ``` ### Use With n8n, Make, or Zapier Save one Task per competitor store group and schedule it daily or weekly. In n8n, Make, or Zapier, wait for the run to finish, then read dataset rows or the `SLACK_ALERTS` key-value output. Typical workflow: 1. Run once to create a baseline catalog snapshot. 2. Schedule the same input. 3. Filter rows with `newProduct` or price/availability change fields. 4. Send changed products to Sheets, Airtable, Slack, or a pricing-review queue. ### Output ```json { "storeDomain": "demo-shop.example", "productTitle": "Everyday Runner", "productUrl": "https://demo-shop.example/products/everyday-runner", "minPrice": 89, "maxPrice": 89, "variantCount": 2, "availableVariantCount": 1, "newProduct": true, "changeTypes": ["new_product"] } ``` ### Why This Is Useful Generic ecommerce scrapers are brittle and often aimed at hostile marketplaces. This Actor is narrower: public Shopify catalogs only, clean product rows, and scheduled diff fields. Use it to: - monitor competitor Shopify catalogs - detect new products - track price and compare-at price changes - watch availability changes - export product datasets to Sheets, BI tools, or internal dashboards ### Pricing Use pay per event: - event: `shopify-product` - suggested price: `$0.002` per emitted product record - dry runs free - first 25 live product records free for free-plan users where Apify runtime billing context allows it ### Limits - Not every Shopify store exposes `products.json`. - Availability means public catalog availability, not guaranteed inventory. - Currency is not always available from `products.json`. - Verify high-impact pricing or availability changes on the product page before acting. # Actor input Schema ## `storeDomains` (type: `array`): Shopify store domains to fetch from public products.json endpoints. ## `maxProductsPerStore` (type: `integer`): Maximum products to emit per store. ## `includeVariants` (type: `boolean`): Include variant-level prices, SKUs, compare-at prices, and availability. ## `includeImages` (type: `boolean`): Include product image URLs. ## `compareToPreviousRun` (type: `boolean`): Store product snapshots and flag new products, price changes, and availability changes on later runs. ## `snapshotStoreName` (type: `string`): Key-value store name for previous product snapshots. ## `requestTimeoutMs` (type: `integer`): Per-request timeout in milliseconds. ## `dryRun` (type: `boolean`): Emit deterministic demo records without network calls or custom pay-per-event charges. ## Actor input object example ```json { "storeDomains": [ "allbirds.com" ], "maxProductsPerStore": 250, "includeVariants": true, "includeImages": true, "compareToPreviousRun": true, "snapshotStoreName": "shopify-catalog-price-monitor-snapshots", "requestTimeoutMs": 10000, "dryRun": true } ``` # Actor output Schema ## `results` (type: `string`): No description ## `productExport` (type: `string`): No description ## `runSummary` (type: `string`): No description # 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("orbiscribe/shopify-catalog-price-monitor").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("orbiscribe/shopify-catalog-price-monitor").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 orbiscribe/shopify-catalog-price-monitor --silent --output-dataset ``` ## MCP server setup ```json { "mcpServers": { "apify": { "command": "npx", "args": [ "mcp-remote", "https://mcp.apify.com/?tools=orbiscribe/shopify-catalog-price-monitor", "--header", "Authorization: Bearer " ] } } } ``` ## OpenAPI specification ```json { "openapi": "3.0.1", "info": { "title": "Shopify Catalog and Price Change Monitor", "description": "Extract public Shopify product catalogs from store domains and monitor product, variant, price, compare-at price, image, and availability changes.", "version": "0.1", "x-build-id": "aWFBZjVTqReJfmcXl" }, "servers": [ { "url": "https://api.apify.com/v2" } ], "paths": { "/acts/orbiscribe~shopify-catalog-price-monitor/run-sync-get-dataset-items": { "post": { "operationId": "run-sync-get-dataset-items-orbiscribe-shopify-catalog-price-monitor", "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/orbiscribe~shopify-catalog-price-monitor/runs": { "post": { "operationId": "runs-sync-orbiscribe-shopify-catalog-price-monitor", "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/orbiscribe~shopify-catalog-price-monitor/run-sync": { "post": { "operationId": "run-sync-orbiscribe-shopify-catalog-price-monitor", "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": { "storeDomains": { "title": "Shopify store domains", "type": "array", "description": "Shopify store domains to fetch from public products.json endpoints.", "default": [ "allbirds.com" ] }, "maxProductsPerStore": { "title": "Max products per store", "minimum": 1, "maximum": 5000, "type": "integer", "description": "Maximum products to emit per store.", "default": 250 }, "includeVariants": { "title": "Include variants", "type": "boolean", "description": "Include variant-level prices, SKUs, compare-at prices, and availability.", "default": true }, "includeImages": { "title": "Include images", "type": "boolean", "description": "Include product image URLs.", "default": true }, "compareToPreviousRun": { "title": "Compare to previous run", "type": "boolean", "description": "Store product snapshots and flag new products, price changes, and availability changes on later runs.", "default": true }, "snapshotStoreName": { "title": "Snapshot store name", "type": "string", "description": "Key-value store name for previous product snapshots.", "default": "shopify-catalog-price-monitor-snapshots" }, "requestTimeoutMs": { "title": "Request timeout", "minimum": 1000, "maximum": 30000, "type": "integer", "description": "Per-request timeout in milliseconds.", "default": 10000 }, "dryRun": { "title": "Dry run", "type": "boolean", "description": "Emit deterministic demo records without network calls or custom pay-per-event charges.", "default": true } } }, "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 } } } } } } } } } } ```