Scheduled aggregation best practices

Working with Data
7

Hi @Pavel_Duchovny,

my latest varsion of full code I inserted above sample function:

exports = async function aggregation() {
var db = "WoocommerceRiskViaIntegromat";
var sourceColl = "ordersExtended";
var collection = context.services.get("Cluster0").db(db).collection(sourceColl);
        var pipeline =[
    {
    '$project': {
      'businessMeta.client_id': true, 
      'businessMeta.client_name': true, 
      'businessMeta.webshop_id': true, 
      'businessMeta.webshop_name': true, 
      'numVerify.valid': true, 
      'numVerify.international_format': true, 
      'numVerify.country_prefix': true, 
      'numVerify.country_code': true, 
      'numVerify.location': true, 
      'order.id': true, 
      'order.status': true, 
      'order.currency': true, 
      'order.total': true, 
      'order.date_created': true, 
      'order.date_modified': true, 
      'order.date_paid': true, 
      'order.date_completed': true, 
      'order.customer_id': true, 
      'order.customer_ip_address': true, 
      'order.customer_user_agent': true, 
      'order.customer_note': true, 
      'order.payment_method': true
    }
  }, {
    '$sort': {
      'order.date_modified': -1
    }
  }, {
    '$out': 'ordersProcessedAndSorted'
  }
  ]; //Paste pipeline
    
await collection.aggregate(pipeline).toArray();

}

Thank you!

1 Like