Function aggregate with out stage

[Nanno_Scheringa]

I’ve created a function with an aggregate on a collection. The last stage is the $out.

When I run the function in the function editor, the function create the collection in the $out stage.

When I create a trigger that schedules the function. The function doesn’t seems to work, there is no collection created.

All seems configured correct, but off course I’m missing something. Anyone some pointerd for me to look at?

thnx

Nanno

[Pavel_Duchovny]

Hi Nanno,

What is the authentication . method defined on the function?

Make sure it is set to SYSTEM, $otherwise not sure the $out can work otherwise.

Also can you send us the link to the relevant trigger?

Thanks,
Pavel

[Nanno_Scheringa]

Hi Pavel,

in the settings of the function, the authentication is set to System.

@Pavel_Duchovny Can I send you the link to the function in a DM? Or do have to post it here?

thnanks,
Nanno

[Pavel_Duchovny]

Hi @Nanno_Scheringa,

Sure you can send me a DM…

Regards,
Pavel

[Nanno_Scheringa]

Hi @Pavel_Duchovny,

don’t see how I can send you a DM in the community.

So this is the link to the trigger: https://cloud.mongodb.com/v2/5e18d130d5ec131001d33210#triggers/5f0d82b5f99d6b43dc30376e

regards,
Nanno

[Pavel_Duchovny]

Hi @Nanno_Scheringa,

I see that the trigger works fast and not producing any errors. I am afraid its due to the asynchronous logic of a return command used in the function not allowing the $out to complete.

Can you edit the function as following:

exports = async function() { 
...
...
var aggResult =  await shipmentsCollection.aggregate(pipeline).toArray();
return aggResult;

Let me know how that works.

Best regards,
Pavel

[Nanno_Scheringa]

Hi @Pavel_Duchovny

I changed the function as mentioned. And now I’m getting the results I’m expecting. Great!

Thanx for the support and your help.

Regards
Nanno