Create Workflow that find assets

Question

hello, I am new to Collibra workflows and the groovy language so I am having a little trouble creating my workflow.I am trying to get assets that have been created after a certain time. I have found to classes that could be the solution : OutputModuleApi and FindAssetsRequest. here is the code i have written so far : import com.collibra.dgc.core.api.component.queryoutputmodule.OutputModuleApiassets = OutputModuleApi.exportJSON(ExportJSONRequest({"ViewConfig": {"Resources": {"Asset": {"Id": { "na...

Sean Pyle · Answer

Hey Tom, not sure what your use case is, but you may have better luck querying the assets with Knowledge Graph API, using a tool like Postman. This will work if you're just trying to get the data about which assets were created on a certain day.

If you need to tie this to some automation in Collibra, a workflow is your best bet. I would recommend looking at activityStreamApi.getActivities(FindActivitiesRequest.builder()) to find assets that were created during a certain time period.

I'm taking a guess at what you might need, so you'll need to tweak this. I didn't test this, but I'm just trying to point you in the right direction:

import com.collibra.dgc.core.api.model.activitystream.ActivityType // import class for activityType method
import com.collibra.dgc.core.api.dto.activitystream.FindActivitiesRequest // import class for FindActivities Request

 Calendar day = Calendar.getInstance(); //get current date and time....you can use something different if you want to track a specific day
today = day.getTimeInMillis() //start date needs to be in epoch mills. use getTimeInMillis on the date to convert it to epochmillis

def newAssets = activityStreamApi.getActivities(FindActivitiesRequest.builder() // define newAssets variable and call FindActivitiesRequest builder
                                            .activityType(ActivityType.valueOf("ADD")) //filter activity type you are searching for to "ADD"
                                               .startDate(today) 
                                               .build()
                                               ).getResults() 

loggerApi.info(newAssets) // view results in Collibra Console logs

You might want to consider taking some of our courses on Workflow Designer on Collibra University to get the fundamentals down if you still find some issues.

Hope this helps!

tomwilliams1 · Answer

just note there is a new line between OutputModuleApi and assets, thank you

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