How to create CSV file using Collibra Workflow?

Question

I have a variable that contains a string. This string is a comma separated asset Ids. Now I need to have this Asset Ids be stored in a CSV file through the help of a workflow.Is it possible?Thank you!

Sean Pyle · Answer

Check out this example I created, which will make a csv file and attach it to an asset in Collibra. I haven't figured out how to get the file without attaching to an asset, but let me know if you figure it out! /* * Example Groovy Script for Collibra Workflow */ import java.util.stream.Collectors import com.collibra.dgc.core.api.dto.file.AddFileRequest import java.io.InputStream import java.io.ByteArrayInputStream import com.collibra.dgc.core.api.dto.instance.attachment.AddAttachmentRequest // 1. Define your UUIDs as strings or however you want to retreive them // These could come from workflow variables, API calls, or be hardcoded. def uuid1 = "1a2b3c4d-5e6f-7a8b-9c0d-1e2f3a4b5c6d" def uuid2 = "f1e2d3c4-b5a6-9f8e-7d6c-5b4a3f2e1d0c" def uuid3 = "a1b2c3d4-e5f6-a7b8-c9d0-e1f2a3b4c5d6" def uuid4 = "c0b9a8f7-e6d5-c4b3-a291-807060504030" // 2. Create a Collection (in this case, a List) containing the UUIDs. Collection<String> uuidCollection = [uuid1, uuid2, uuid3, uuid4] // 3. Call the toCsv method on the 'utility' workflow bean variable. // This will convert the collection into a comma-separated string. // For example: "uuid1,uuid2,uuid3,uuid4" String resultCsvString = utility.toCsv(uuidCollection) // 4. (For Demonstration) Log the output to the workflow logs. loggerApi.info("Successfully converted the collection to a CSV string.") loggerApi.info("Generated CSV: " + resultCsvString) // Convert the CSV string to a downloadable file using AddFileRequest --- try { // 5. Define a unique filename. def fileName = "uuid_export_${System.currentTimeMillis()}.csv" // 6. Create an in-memory InputStream from our CSV string. // We specify UTF-8 encoding for broad compatibility. InputStream fileStream = new ByteArrayInputStream(resultCsvString.getBytes("UTF-8")) // 7. Use the AddFileRequest builder to construct the request object. def addFileRequest = AddFileRequest.builder() .name(fileName) .fileStream(fileStream) .build() // 8. Call the addFile method with the request object. def fileInfo = fileApi.addFile(addFileRequest) loggerApi.info("Successfully attached file to workflow: ${fileInfo.getName()} with ID: ${fileInfo.getId()}") // --- NEW CODE: Retrieve and verify the file content --- loggerApi.info("Now attempting to retrieve the file content for verification...") // 9. Get the UUID of the newly created file. def fileId = fileInfo.getId() // At the end of your 'try' block // 10. Call the getFileAsStream method to get an InputStream of the file. InputStream downloadedStream = fileApi.getFileAsStream(fileId) AddAttachmentRequest attachmentRequest = AddAttachmentRequest.builder() .baseResourceId(item.getId()) .baseResourceType(item.getType()) .fileStream(downloadedStream) .fileName(fileName) .build() attachmentApi.addAttachment(attachmentRequest) // 11. Read the content from the stream and log it. // .text is a Groovy extension method that reads the entire stream into a string. // String downloadedContent = downloadedStream.text // loggerApi.info("Successfully retrieved file content.") // loggerApi.info("Verified Content: " + downloadedContent) } catch (Exception e) { // If anything goes wrong, log the error's message and stop the workflow. loggerApi.error("Failed to create or attach the CSV file. Error: " + e.getMessage()) throw e } // The script is complete. The file is now attached to the workflow. // No temporary file cleanup is needed with this method.

1	Grant Rollerson SUNCORP CORPORATE SERVICES PTY LTD
2	Tom Friesen Algonquin College
3	SB S Benson Plus3 IT
4	S stefan_busch
5	Brian Lloyd USA TODAY Co.
6	D daverichard