dacr

#!/bin/sh
exec scala -nc "$0" "$@"
!#
import scala.io._
import java.io._
import scala.util.matching._

val logfiles=if (args.size==0) List("/var/log/auth.log") else args.toList
val failRE="""^(\w+\s+\d+\s+\d{2}:\d{2}:\d{2}).*: Failed password for(?: invalid user)? (\w+) from ([.0-9A-Fa-f:]+) port.*""".r
val jstrRE=""""(\w+)":"([^"]+)"""".r

baojie

import multiprocessing

# split a list into evenly sized chunks
def chunks(l, n):
    return [l[i:i+n] for i in range(0, len(l), n)]


def do_job(job_id, data_slice):
    for item in data_slice:
        print "job", job_id, item