Changeset 699

Timestamp:

04/11/16 18:36:51 (8 years ago)

Author:

pinsard

Message:

log in main

File:

• trunk/src/file_Tbcorr_daily.py (modified) (7 diffs)

trunk/src/file_Tbcorr_daily.py

@@ -6 +6 @@
 import argparse
 
-from pylab import *
+import inspect
+from datetime import datetime
+import logging
+
+#from pylab import *
 import glob
-from datetime import date
+#from datetime import date
 from useCorrTb_daily import *
 import itertools as it
@@ -28 +32 @@
     parser = argparse.ArgumentParser(description=__doc__,
                                      formatter_class=argparse.RawDescriptionHelpFormatter)
+
+    parser.add_argument("--verbose", 
+                        action='store_true',
+                        default=False,
+                        help=("run in verbose mode."))
 
     ### Satellite, Instrument, Produit Level, Channel
@@ -97 +106 @@
 
     opts = vars(parser.parse_args())
+    is_verbose = opts['verbose']
     lvl = opts['lvl']
     sat = opts['sat']
@@ -106 +116 @@
     latvec = arange(-34.5,34.6,resol)
     lonvec = arange(-180.,179.76,resol)
-    
+
+    # define log file
+    command = '{0}'.format(inspect.stack()[0][3])
+    log_date = datetime.datetime.utcnow().strftime('%Y%m%dT%H%M%SZ')
+    log = '{0}/{1}.log.{2}'.format(os.environ['PROJECT_LOG'], command, log_date)
+
+    logger = logging.getLogger()
+    handler = logging.FileHandler(log)
+    logger.addHandler(handler)
+    if is_verbose:
+        logger.setLevel(logging.DEBUG)
+    else:
+        logger.setLevel(logging.INFO)
+    
+    logger = logging.getLogger()
+    logger.info('[Context]')
+    logger.info('PID={0}'.format(os.getpid()))
+    logger.info('command={0}'.format(command))
+    import socket
+    logger.info('hostname={0}'.format(socket.getfqdn()))
+    logger.info('runtime={0}'.format(log_date))
+    logger.info('log={0}'.format(log))
+
+    logger.info('[Parameters]')
+    logger.info('lvl={0}'.format(lvl))
+    logger.info('sat={0}'.format(sat))
+    logger.info('inst={0}'.format(inst))
+    logger.info('ch={0}'.format(ch))
+    logger.info('dmin={0}'.format(dmin))
+    logger.info('dmax={0}'.format(dmax))
+
     # number of processes
     npr = 10
     
     for day in rrule(DAILY,dtstart=dmin,until=dmax):
-        print day
+        logger.info('{0}'.format(day))
         ### File list
         repday = [day.strftime('%Y_%m_%d')]#[ff.strftime('%Y_%m_%d') for ff in rrule(DAILY,dtstart=day+relativedelta(days=-1),until=day+relativedelta(days=+1))]
@@ -123 +163 @@
         pool.join()
     
-        print 'Join'
+        logger.info('Join')
+
         tbcorr, tobs, satvec = [dstack([proc[var] for proc in res if size(proc[var])]) for var in xrange(3)]
         del res
@@ -141 +182 @@
     
         ### Save in netcdf file
-        print 'Save in nc'
+        logger.info('Save in nc')
         nsat = satvec.size
         nlon = lonvec.size
@@ -191 +232 @@
             # Fermeture du fichier
             ncfile.close()
-            print output+' created'
+            logger.info('{0} created'.format(output))