Commerce Connector: Multi Step - Real-Time Data Exchange Architecture

TABLE OF CONTENTS

Overview

The Commerce Connector with real-time, multi-step data exchange capabilities enables organizations to build flexible, event-driven, and callback-based integrations with external systems such as ERPs, pricing engines, inventory systems, and file-based platforms.

This feature includes:

  • Multi-step integration pipelines
  • Real-time event triggering
  • Real-time storefront callbacks
  • HTTP-based execution framework
  • Backward compatibility with existing scheduled exchanges

These capabilities allow Znode to automatically react to business events, retrieve live data during storefront requests, and orchestrate complex workflows across APIs, SFTP, and Blob Storage.

Key Features

Multi-Step Data Exchanges

Data Exchanges support unlimited sequential steps.

Capabilities

  • Add unlimited integration steps
  • Execute steps sequentially
  • Configure an independent mapper per step
  • Reuse data from previous steps
  • Apply transformations only where required
  • Reference prior step outputs using step prefixes

Example

Step1.Account.Name

Step2.SalesOrderNumber

Supported Transmission Modes

ModeUsage
APIReal-time and lightweight integrations
SFTPLegacy ERP file-based integrations
Blob StorageLarge file exchanges
Import HandlerBulk Znode imports

Trigger Execution Framework (HTTP)

A new Trigger Execution (HTTP) section is available in Manage Data Exchange.

Trigger Execution must be enabled for all multi-step exchanges.

Supported trigger types:

  • Znode Event (Push Model)
  • Znode Callback (Pull Model)

Real-Time Execution Models

Znode Event – Push-Based Execution

Automatically executes a Data Exchange when a configured Znode system event occurs.

Supported Event Modules

  • Account
  • Order
  • Product
  • Category
  • Price
  • Inventory
  • Catalog
  • Portal

Typical Events

  • Account Updated
  • Order Created
  • Product Changed

Example Use Case

Account Updated → Fetch Account Details → Transform Data → Send to ERP or SFTP

Znode Callback – Pull-Based Execution

Retrieves live pricing or inventory data from external systems during storefront requests.

Supported Callback Types

  • Real-time Pricing
  • Real-time Inventory

Supported Storefront Scenarios

  • Real-time pricing on Product Detail Page (PDP)
  • Real-time inventory availability

Callback Behaviour

  1. Shopper initiates storefront request
  2. Znode triggers callback
  3. Commerce Connector calls external API
  4. Response is transformed using Global Mapper
  5. Live data is returned to the storefront

Required Global Mapper Fields

  • Sales Price
  • Retail Price
  • SKU
  • Line-Item ID

When to Use Event-Based vs API-Based Execution

CriteriaEvent-BasedAPI-Based
When to UseWhen event exists in ZnodeWhen event does not exist
TriggerAutomatic system eventManual API invocation
DependencyZnode eventsExternal system
ControlLimitedHigh
Use CasesOrder Created, RegistrationCustom workflows

Configuration: Event-Based Real-Time Execution

Prerequisites

  • Administrator access
  • Commerce Connector enabled
  • Events configured
  • External APIs reachable

Steps

  1. Navigate to Commerce Connector.
  2. Create a Data Exchange.
  3. Enable Trigger Execution.
  4. Select the required Event.
  5. View the Event Payload.
  6. Understand Step 0 (read-only event payload).
  7. Configure the Return Payload option.
  8. Configure the processing steps.
  9. Configure the API request.
  10. Map data between steps.

Example Mapping

Step2.SalesOrderName : Step0.Payload.EventDataCode

Workflow

  1. Znode event occurs.
  2. Trigger validation executes.
  3. Data Exchange starts.
  4. Steps execute sequentially.
  5. Data is transformed.
  6. Operations execute.
  7. Status is logged.

Callback Configuration

  1. Enable the Znode Callback trigger.
  2. Select the required callback action (for example, Real-Time Inventory).
  3. Configure ERP processing steps.

Global Mapper

The Global Mapper executes after all configured steps and formats the final response returned to the storefront.

Mappings should reference the next step prefix.

Step2.QuantityAvailable : Step1.InventoryQuantity

Step2.SKU : Step1.ProductSKU

Execution Flow Summary

  1. Shopper opens Product Detail Page (PDP).
  2. Callback is triggered.
  3. Configured processing steps execute.
  4. ERP API is called.
  5. Global Mapper formats the response.
  6. Live data is returned to the storefront.

Best Practices

  • Enable callback-based integrations wherever applicable.
  • Disable legacy real-time integrations when using callbacks.
  • Keep ERP APIs lightweight and responsive.
  • Use caching wherever possible to reduce external API calls.

Use Cases

Real-Time Order Creation

  • Trigger: Order Created
  • Header and line-item steps execute.
  • ERP Order API is invoked.

Real-Time Pricing

  • Trigger: Product Detail Page load.
  • External pricing API returns the latest price.

Account Updates

  • Trigger: Account Updated.
  • Customer information is synchronized with the ERP.

Multi-Step Enrichment

  • Tax API
  • Shipping API
  • Data from multiple systems is combined before returning the final payload.

Backward Compatibility

  • Existing scheduled exchanges continue to function without modification.
  • No migration is required for existing scheduled integrations.

Important Notes and Limitations

Important Conditions

  • Callback Data Exchanges must be enabled.
  • Legacy real-time Pricing and Inventory integrations must be disabled for callback execution.
  • Disabling callback exchanges reverts storefront pricing and inventory to stored Znode values.

Current Limitations

The following capabilities are currently not supported:

  • Advanced retry monitoring UI.
  • Pagination and aggregation in multi-step flows.
  • Copying multi-step Data Exchanges.
  • Custom processors in multi-step flows.
  • Individual step-level data logging.
  • Advanced monitoring dashboards.

Prerequisites

Before configuring Real-Time Eventing or Callback:

  • Administrator access to the Znode Admin Console.
  • Commerce Connector must be enabled.
  • External APIs or endpoints must be reachable.
  • ERP, SFTP, or Blob Storage configurations must be available.
  • Legacy real-time Pricing and Inventory integrations must be disabled for callback scenarios.

Scheduler & Exchange Recommendations

Supported Scheduler Types

Scheduler TypePurpose
ScheduledAutomated recurring exchanges
OnDemandManual execution
RealTimeEvent-triggered immediate processing
Exchange TypeRecommended Frequency
Inventory SyncEvery 15 minutes
Order ExportEvery 15–30 minutes
Price SyncEvery 4 hours
Product ImportDaily
Full Catalog SyncWeekly

Important Scheduler Guidelines

  • Do not configure scheduler intervals below 5 minutes.
  • High-frequency jobs may overload Hangfire queues.
  • Large exchanges should be scheduled during off-peak hours.
  • Long-running jobs should use dedicated queues whenever possible.

Pagination & Data Volume Recommendations

Data TypeRecommended Page SizeMaximum Recommended
Inventory5005,000
Orders2003,000
Products2503,000
Prices1,0005,000
Customers2503,000

Pagination Guidelines

  • Pagination should always be enabled for API-based exchanges.
  • Page sizes above 1,000 may cause memory pressure.
  • Very small page sizes increase HTTP overhead.
  • Large payloads increase serialization and deserialization costs.
ParameterRecommended Maximum
Export records per file5,000
Export file size50 MB
API payload size10 MB
Concurrent export jobs3 per server

Real-Time Processing Guidelines

Real-Time Processing Characteristics

Real-time exchanges execute as synchronous HTTP operations.

The request lifecycle includes:

  1. Request received
  2. Processor execution
  3. ERP/Znode API communication
  4. Data transformation
  5. Immediate response returned
Recommended UsageNot Recommended
Single order processingBulk catalog synchronization
Single SKU inventory lookupLarge inventory exports
Order acknowledgmentFull price synchronization
Lightweight API workflowsLarge batch operations
MetricRecommended
Response Time< 2 seconds
Payload Size< 1 MB
Concurrent Requests< 20
ERP API Latency< 500 ms

Real-Time Operational Risks

  • Real-time exchanges are blocking operations.
  • Slow ERP APIs directly impact storefront performance.
  • No queue buffering exists for real-time requests.
  • High concurrency may saturate API thread pools.

Inventory Synchronization Recommendations

ScenarioRecommended Mode
Product page inventory checkReal-Time
Warehouse inventory syncScheduled
Full inventory reconciliationFile-based

Inventory Synchronization Risks

  • Real-time inventory calls execute inline with storefront requests.
  • Slow ERP APIs increase storefront latency.
  • No native in-process inventory caching exists.
  • High inventory traffic can overload ERP systems.
  • Enable Redis caching for inventory lookups.
  • Use short cache expiration windows (2–5 minutes).
  • Prefer scheduled synchronization for large catalogs.
  • Avoid bulk real-time inventory requests.

Transmission Modes & File Processing

Supported Transmission Modes

ModeRecommended Usage
APIReal-time and lightweight integrations
SFTPLegacy ERP file integrations
Blob StorageLarge file exchange
Import HandlerBulk Znode imports
Import TypeRecommended Batch Size
Product Import1,000–10,000
Price Import2,500–10,000
Inventory Import2,500–10,000
Category Import500–1,000
Promotions500

File Processing Recommendations

  • Split large files into smaller batches.
  • Avoid processing files larger than 50 MB.
  • Prefer Blob Storage or SFTP for high-volume integrations.
  • Increase timeout values for large imports where necessary.

Infrastructure Sizing Recommendations

EnvironmentCPUMemoryRecommended Instances
Small1 vCPU2 GB1
Mid-Market2 vCPU4 GB2
Enterprise3+ vCPU8–16 GB3+

Known Limitations & Constraints

Architecture Limitations

IDLimitationImpact
L1No hard-coded maximum record limit per exchangeLarge exchanges may cause memory pressure.
L2Real-time processing is synchronous.Caller blocks until processing completes.
L3Event queues may be temporary.Events may be lost during application restart.
L4No built-in Dead Letter Queue (DLQ).Failed events may be discarded.
L5Shared Hangfire queue.Long-running jobs may block short jobs.
L6Pagination retry counts are partially hardcoded.Limited runtime tuning.
L7SQL parser timeout constraints.Large parsing jobs may fail.
L8No built-in real-time rate limiting.ERP APIs may become overloaded.
L9SFTP reconnects for every file.May be slow when processing many small files.
L10Real-time calls execute inline.No buffering or asynchronous queueing.

Operational Constraints

ConstraintDetails
Minimum Scheduler Interval5 minutes recommended.
Real-Time Payload Size10 MB maximum recommended.
Export File Size50 MB recommended maximum.
API Page Size5,000 recommended maximum.
Concurrent Real-Time RequestsMore than 20 concurrent requests may impact system stability.

Exchange TypeRecommended Limit
Product Import10,000 rows per batch
Price Import10,000 rows per batch
Inventory Import10,000 rows per batch
Category Import2,000 rows per batch

Unsupported Configurations & Anti-Patterns

The following implementation patterns are not recommended and may negatively impact performance or system stability.

Anti-PatternRisk
Real-time full catalog synchronizationAPI thread exhaustion.
Real-time bulk inventory updatesERP overload.
Page sizes greater than 5,000Memory spikes.
CRON execution every 30 secondsHangfire queue saturation.
Single-node RabbitMQ deploymentsSingle point of failure.
Very large XML payloadsHigh memory allocation.
Running all workloads on a single queueQueue starvation.
Large synchronous ERP callsStorefront slowness.

Note: The recommendations and limits documented in this article are intended as general best practices for production environments. Actual values may vary depending on infrastructure sizing, ERP performance, network latency, integration complexity, and overall system workload. These recommendations should be validated and adjusted based on your deployment requirements and performance testing.

Performance Recommendations

MetricRecommended Target
Response Time< 2 seconds
Payload Size< 1 MB
ERP API Latency< 500 ms

Summary

Znode’s real-time, multi-step data exchange framework enables organizations to build scalable, event-driven integrations that support real-time automation, live data retrieval, and complex multi-step workflows across APIs, SFTP, and Blob Storage. The framework maintains backward compatibility with existing scheduled data exchanges, allowing organizations to modernize integrations without impacting existing implementations.

Did you find it helpful? Yes No

Send feedback
Sorry we couldn't be helpful. Help us improve this article with your feedback.