Create a Fabric Lakehouse File Writer application

In Striim, select Apps > Create New, enter Fabric Lakehouse in the search bar, click the kind of application you want to create, and follow the prompts. See for Creating apps using wizards more information.Creating apps using templates

The following sample application writes from Oracle to a Microsoft Fabric Lakehouse.

CREATE APPLICATION App;

CREATE SOURCE OracleSrc USING Global.OracleReader ( 
  TransactionBufferDiskLocation: '.striim/LargeBuffer', 
  ConnectionURL: 'localhost:1521:ORCL', 
  Tables: 'QATEST.TESTFILE', 
  Compression: false, 
  connectionRetryPolicy: 'timeOut=30, retryInterval=30, maxRetries=3', 
  Password_encrypted: 'true', 
  SupportPDB: false, 
  QuiesceMarkerTable: 'QUIESCEMARKER', 
  FetchSize: 1000, 
  CDDLAction: 'Process', 
  DictionaryMode: 'OnlineCatalog', 
  QueueSize: 2048, 
  CommittedTransactions: true, 
  SetConservativeRange: false, 
  CDDLCapture: false, 
  Password: 'dwMnzwaVBbvGwoBI6UM/yw==', 
  TransactionBufferType: 'Disk', 
  Username: 'qatest', 
  TransactionBufferSpilloverSize: '100MB', 
  FilterTransactionBoundaries: true, 
  SendBeforeImage: true, 
  DatabaseRole: 'Primary' ) 
OUTPUT TO o1;

CREATE TARGET LakehouseTrg USING Global.FabricLakehouseFileWriter ( 
  Url: 'https://onelake.dfs.fabric.microsoft.com/<workspace>/<item>.la/Files', 
  filename: 'testOracle.csv', 
  directory: 'testOracle', 
  Password: <password>, 
  Username:<username>) 
FORMAT USING Global.DSVFormatter  ( 
  quotecharacter: '\"', 
  columndelimiter: ',', 
  members: 'data', 
  nullvalue: 'NULL', 
  usequotes: 'false', 
  rowdelimiter: '\n', 
  standard: 'none', 
  header: 'false' ) 
INPUT FROM o1;

END APPLICATION App;

The following sample application writes from a file to a Microsoft Fabric Lakehouse.

CREATE APPLICATION App;

CREATE SOURCE FileSrc USING Global.FileReader ( 
  rolloverstyle: 'Default', 
  blocksize: 64, 
  wildcard: '*.csv', 
  skipbom: true, 
  directory: '/tmp/fileTest/csvIn', 
  includesubdirectories: false, 
  positionbyeof: false ) 
PARSE USING Global.DSVParser ( 
  trimwhitespace: false, 
  commentcharacter: '', 
  linenumber: '-1', 
  columndelimiter: ',', 
  trimquote: true, 
  columndelimittill: '-1', 
  ignoreemptycolumn: false, 
  separator: ':', 
  quoteset: '\"', 
  charset: 'UTF-8', 
  ignoremultiplerecordbegin: 'true', 
  ignorerowdelimiterinquote: false, 
  header: false, 
  blockascompleterecord: false, 
  rowdelimiter: '\n', 
  nocolumndelimiter: false, 
  headerlineno: 0 ) 
OUTPUT TO o1;

CREATE TARGET LakehouseTrg USING Global.FabricLakehouseFileWriter ( 
  filename: 'testDsv.csv', 
  Url: 'https://onelake.dfs.fabric.microsoft.com/<workspace>/<item>.lakehouse/Files', 
  directory: 'csvTest', 
  Username: <username>',  
  Password: <password>) 
FORMAT USING Global.DSVFormatter  ( 
  quotecharacter: '\"', 
  columndelimiter: ',', 
  members: 'data', 
  nullvalue: 'NULL', 
  usequotes: 'false', 
  rowdelimiter: '\n', 
  standard: 'none', 
  header: 'false' ) 
INPUT FROM o1;

END APPLICATION App;