In this recipe, we will guide you through creating a transformation that loads data from different files in your filesystem, and then load them into a MongoDB Collection. We are going to load data from files called orders.csv, customers.xls, and products.xml. Each of these files contains a key that we can use to join data in PDI before we send it to the MongoDB Output step.
Start Spoon and take a look at the content of the orders.csv, customers.xls, and products.xml files. This will help you understand what the data looks like before you start loading it into MongoDB.
You will need the orders.csv, customers.xls, and products.xml files. These files will be available at the Packt Publishing website, just in case you don't have them. Make sure that MongoDB is up and running, and then you will be able to perform to the following steps:
Create a new empty transformation.
Set the transformation name to Migrate data from files to MongoDB.
Save the transformation with the name chapter1-files-to-mongodb.
Select data from the orders.csv file using the CSV file input step.
Select the Design tab in the left-hand-side view.
From the Input category folder, find the CSV file input step and drag and drop it into the working area in the right-hand-side view.
Double-click on the step to open the CSV Input configuration dialog.
Set Step Name to Select Orders.
In the Filename field, click on the Browse button, navigate to the location of the
.csvfile, and select the order.csv file.Set the Delimiter field to a semicolon (
;).Now, let's define our output fields by clicking on the Get Fields button. A Sample size dialog will appear; it is used to analyze the format data in the CSV file. Click on OK. Then, click on Close in Scan results.
Click on OK to finish the configuration of the CSV file input.
Select data from the customers.xls file using the Microsoft Excel Input step.
Select the Design tab in the left-hand-side view.
From the Input category folder, find the Microsoft Excel Input step and drag and drop it into the working area in the right-hand-side view.
Double-click on the step to open the Microsoft Excel Input dialog.
Set Step Name to Select Customers.
On the Files tab, in the File or directory field, click on the Browse button and choose the location of the customers.xls file in your filesystem. After that, click on the Add button to add the file to the list of files to be processed.
Select the Sheets tab. Then, click on the Get sheetname(s)... button. You'll be shown an Enter list dialog. Select Sheet1 and click on the > button to add a sheet to the Your selection list. Finally, click on OK.
Select the Fields tab. Then, click on the Get field from header row... button. This will generate a list of existing fields in the spreadsheet. You will have to make a small change; change the Type field for Customer Number from Number to Integer. You can preview the file data by clicking on the Preview rows button.
Click on OK to finish the configuration of the Select Customers step.
Select data from the products.xml file using the Get data from XML step.
Select the Design tab in the left-hand-side view.
From the Input category folder, find the Get data from XML step and drag and drop it into the working area in the right-hand-side view.
Double-click on the step to open the Get data from XML dialog.
Set Step Name to Select Products.
On the File tab, in the File or directory field, click on the Browse button and choose the location of the products.xml file in your filesystem. After that, click on the Add button to add the file to the list of files to be processed.
Select the Content tab. Click on the Get XPath nodes button and select the /products/product option from the list of the Available Paths dialog.
Next, select the Fields tab. Click on the Get fields button and you will get a list of available fields in the XML file. Change the types of the last three fields (stockquantity, buyprice, and MSRP) from Number to Integer. Set the Trim Type to Both for all fields.
Now, let's join the data from the three different files.
Select the Design tab in the left-hand-side view.
From the Lookup category folder, find the Stream lookup step. Drag and drop it onto the working area in the right-hand-side view. Double-click on Stream lookup and change the Step name field to Lookup Customers.
We are going to need two lookup steps for this transformation. Drag and drop another Stream Lookup step onto the design view, and set Step Name to Lookup Products.
Create a hop between the Select Orders step and the Lookup Customers step.
Then, create a hop from the Select Customers step to the Lookup Customers step.
Next, create a hop from the Lookup Customers step to the Lookup Products step.
Finally, create a hop from Select Products to the Lookup Products step.
Let's configure the Lookup Customers step. Double-click on the Lookup Customers step and set the Lookup step field to the Select Customers option.
Let's configure the Lookup Products step. The process is similar to that of the Lookup Customers step but with different values. Double-click on the Lookup Products step and set the Lookup step field to the Select Products option.
In the Keys section, set Field to Product Code and the LookupField option to Code.
Click on the Get lookup fields button. This will populate the step with all the available fields from the lookup source. Remove Code from the field in the list.
Click on OK to finish.
Now that we have the data joined correctly, we can write the data stream to a MongoDB collection.
On the Design tab, from the Big Data category folder, find the MongoDB Output step and drag and drop it into the working area in the right-hand-side view.
Create a hop between the Lookup Products step and the MongoDB Output step.
Double-click on the MongoDB Output step and change the Step name field to Orders Output.
Select the Output options tab. Click on the Get DBs buttons and select the SteelWheels option for the Database field. Set the Collection field to Orders. Check the Truncate collection option.
Select the Mongo document fields tab. Click on the Get fields button and you will get a list of fields from the previous step.
Configure the Mongo document output as seen in the following screenshot:
Click on OK.
You can run the transformation and check out MongoDB for the new data. Your transformation should look like the one in this screenshot:
In this transformation, we initially get data from the Orders CSV. This first step populates the primary data stream in PDI. Our other XLS and XML steps also collect data. We then connect these two streams of data to the first stream using the Lookup steps and the correct keys. When we finally have all of the data in the single stream, we can load it into the MongoDB collection.