Connectors Infor LN and M3 to Snowflake

Infor LN and M3 to Snowflake: full history landed and reconciled, then kept current.

Lima Backbone reads Infor LN and M3 through ION API gateway, types the data correctly on landing, writes it into Snowflake as three schemas: raw (as arrived), conformed (current state by key) and history (every version), and keeps it current from the source’s changes. Every run ends with a row count and a control total per table.

OUT OF INFOR LN AND M3ItemsItem master · item warehouseBills of materialProduct structure BODsRoutingsRouting BODsStockInventory balance BODsLIMA BACKBONEExtractION API gateway · Business object docume…Checknine checks before anything loadsShapetypes, keys, deletes, partitionsLoadParquet to an internal stage, COPY INTO…INTO SNOWFLAKESnowflakeThree schemas: RAW (as arrived), CONFORM…
The path from Infor LN and M3 to Snowflake. Objects come out through the source's methods, are typed and checked, land in Snowflake and are kept current from the source's changes.
220M rows
615 tables · ~30 GB in ~30 min on 64 vCPU
performance estimate
80 GB/day
moved and transformed every day
production · semiconductor enterprise
8
checks on landing
product
1
count and control total per table per run
product
What Snowflake expects

The model the load has to fit.

ModelThree schemas: RAW (as arrived), CONFORMED (current state by key) and HISTORY (every version). Types set from the source, including SAP dates and currency decimals.LoadParquet to an internal stage, COPY INTO RAW, MERGE into CONFORMED, append to HISTORY; a row count and control total per table per run.BackSnowflake is the copy. Results computed there can be written back to the ERP by Lima with the same confirmation.
The hardest part of this path

Getting SAP and Oracle types right on landing: text dates and times, currency decimals, zero-padded keys and client or organisation columns.

The Snowflake connector page →

What comes out of Infor LN and M3

Objects and where they go.

The first load is assembled from these objects through ION API gateway. Change capture (BOD publications) keeps the daily volume small afterwards.

Planning objectSource objectsDestination in Snowflake
ItemsItem master · item warehouseRAW table → CONFORMED table (MERGE) → HISTORY
Bills of materialProduct structure BODsRAW table → CONFORMED table (MERGE) → HISTORY
RoutingsRouting BODsRAW table → CONFORMED table (MERGE) → HISTORY
StockInventory balance BODsRAW table → CONFORMED table (MERGE) → HISTORY
Open purchase ordersPurchase order BODsRAW table → CONFORMED table (MERGE) → HISTORY
Open sales ordersSales order BODsRAW table → CONFORMED table (MERGE) → HISTORY
Production ordersProduction order BODsRAW table → CONFORMED table (MERGE) → HISTORY
ForecastsForecast BODsRAW table → CONFORMED table (MERGE) → HISTORY
Customers and suppliersBusiness partner BODsRAW table → CONFORMED table (MERGE) → HISTORY
CalendarsCalendar objectsRAW table → CONFORMED table (MERGE) → HISTORY
The path, step by step

Six steps, one report at the end.

ConnectRegister Infor LN and M3 and Snowflake with credentials from the vault; test both connections.
ExtractFirst load through ION API gateway; then BOD publications.
CheckNine checks run before anything loads; a failed row becomes an exception with an owner and the load continues with the valid rows.
ShapeTypes are set from the source, keys kept complete, deletes and late changes applied in order.
LoadParquet to an internal stage, COPY INTO RAW, MERGE into CONFORMED, append to HISTORY; a row count and control total per table per run.
Keep currentChanges from Infor LN and M3 are applied on the schedule you set; every run ends with the same report.
The checks that run before anything loads

8 checks, each with a plain example.

Every check either passes a row or turns it into an exception record with an owner. Nothing is dropped silently.

CheckKindWhat it catches, with an example
Types set from the sourcetypingSAP dates and times stored as text become dates and times; currency decimals shifted by the currency's rule
Keys complete and uniquekeysclient or organisation columns kept in the key; zero-padded keys preserved
Deletes appliedconsistencyrows deleted in the source are marked or removed in the copy
Late changes land in orderconsistencya change that arrives after a later one is applied by its source timestamp
Wide and cluster tables completecompletenessevery column of a wide table lands; cluster tables read through the released module
Partitions cover the rangecompletenessevery date partition present; gaps reported
Counts and control totals matchreconciliationrows and amounts per table compared between source and target
Schema changes noticeddrifta new or changed column is flagged before it breaks a downstream query
Cadence and offer

How the copy stays current, and how the work is priced.

After the first landing, Snowflake receives the source's changes: BOD publications. A migration month costs the same as a quiet month on the same tier.

Terms on this page

Plain meanings.

LandingWriting rows into the target's raw layer as they arrived, typed, before any business transformation.
Referential orderLoading parents before children so every row finds what it refers to.
Control totalThe sum of a key amount column compared between source and target, along with the row count.
Exception recordA row that failed a check: kept, routed to an owner, replayed once fixed.
Change captureReading only the rows that changed, from a log, change pointers or timestamps.
Questions

Asked about this path.

How long until the first load is live?

Days for the first tables; a full-history migration is sized by table count and volume, and read in partitions inside the run windows your administrators allow.

What does the data team see?

Counts per step, the check that stopped a row, the owner and the replay point, and the lineage of any number back to its source column.

Who runs it after go-live?

Your team, on the schedule you set, with the same report after every run; or your systems integrator; or Lima's team under the subscription.

Land your first tables in Snowflake.

One call scopes the dataset, the run window and the tier. The reconciliation report at the end is the acceptance test.