aggregate-project.py

{
  '$project': {
    'quarterStart': {
      '$subtract': [
        '$timestamp',
        {
          '$add': [
            {
              '$multiply': [
                {
                  '$mod': [  # $minutes mod 15
                    {
                      '$minute': '$timestamp'
                    },
                    15
                  ]
                },
                1000,
                60
              ]
            },
            {
              '$multiply': [
                {
                  '$second': '$timestamp'
                },
                1000
              ]
            },
            {
              '$millisecond': '$timestamp'
            },
          ]
        }
      ]
    },
    'recipients': 1,
    'client_code': 1
  },
},