charlesBochet

{
  '$unwind': '$client_code'
},

charlesBochet

{
  '$group': {
    '_id': {
      'quarterStart': '$quarterStart',
      'recipient': '$recipients',
      'clientCode': '$client_code'
    },
    'count': {
      '$sum': 1
    }

charlesBochet

{
  '$sort': {
    'count': -1
  }
},

charlesBochet

{
  '$group': {
    '_id': {
      'quarterStart': '$_id.quarterStart',
      'clientCode': '$_id.clientCode'
    },
    'recipients': {
      '$push': {
        'recipient': '$_id.recipient',
        'count': '$count'

charlesBochet

{
  '$project': {
    'quarterStart': '$_id.quarterStart',
    'clientCode': '$_id.clientCode',
    'recipients': {
      '$slice': ["$recipients", 1000]
    },
    'totalCount': '$totalCount',
    'recipientsCount': '$recipientsCount'
  }

charlesBochet

for document in aggregation_inbound_malware:
  dst_data_db.IronmailAggregatedInboundTrafficMalwareRecipients.update_one(
    {'_id': document['_id']},
    {'$set': document},
    True
  )

charlesBochet

$BOX = "centos/7"
$IP = "10.0.0.10"
$MEMORY = ENV.has_key?('VM_MEMORY') ? ENV['VM_MEMORY'] : "1024"
$CPUS = ENV.has_key?('VM_CPUS') ? ENV['VM_CPUS'] : "1"

Vagrant.configure("2") do |config|
  config.vm.hostname = "text-analyzer.dev"
  config.vm.box = $BOX
  config.vm.network :private_network, ip: $IP
  config.vm.network "public_network"

charlesBochet

  config.vm.provision "ansible" do |ansible|
    ansible.playbook = "provisioning/playbook.yml"
    ansible.sudo = true
    ansible.limit = "all"
  end

charlesBochet

---

- hosts: all
  gather_facts: False

  tasks:
  - name: Ensure git is installed.
    yum:
      name: git
      state: installed

charlesBochet

---

- hosts: all
  gather_facts: True
  become: true

  tasks:
  - name: Ensure git is installed.
    yum:
      name: git