source: branches/alma/python/__init__.py@ 1612

Last change on this file since 1612 was 1612, checked in by Takeshi Nakazato, 16 years ago

New Development: No

JIRA Issue: Yes CAS-729, CAS-1147

Ready to Release: Yes

Interface Changes: No

What Interface Changed: Please list interface changes

Test Programs: List test programs

Put in Release Notes: Yes

Module(s): Module Names change impacts.

Description: Describe your changes here...

I have changed that almost all log messages are output to casapy.log,
not to the terminal window. After this change, asap becomes to depend on casapy
and is not running in standalone, because asap have to import taskinit module
to access casalogger.


  • Property svn:eol-style set to native
  • Property svn:keywords set to Author Date Id Revision
File size: 24.8 KB
Line 
1"""
2This is the ATNF Single Dish Analysis package.
3
4"""
5import os,sys,shutil, platform
6
7# Set up CASAPATH and first time use of asap i.e. ~/.asap/*
8plf = None
9if sys.platform == "linux2":
10 if platform.architecture()[0] == '64bit':
11 plf = 'linux_64b'
12 else:
13 plf = 'linux_gnu'
14elif sys.platform == 'darwin':
15 plf = 'darwin'
16else:
17 # Shouldn't happen - default to linux
18 plf = 'linux'
19asapdata = __path__[-1]
20# Allow user defined data location
21if os.environ.has_key("ASAPDATA"):
22 if os.path.exists(os.environ["ASAPDATA"]):
23 asapdata = os.environ["ASAPDATA"]
24# use CASAPATH if defined and "data" dir present
25if not os.environ.has_key("CASAPATH") or \
26 not os.path.exists(os.environ["CASAPATH"].split()[0]+"/data"):
27 os.environ["CASAPATH"] = "%s %s somwhere" % ( asapdata, plf)
28# set up user space
29userdir = os.environ["HOME"]+"/.asap"
30if not os.path.exists(userdir):
31 print 'First time ASAP use. Setting up ~/.asap'
32 os.mkdir(userdir)
33 #shutil.copyfile(asapdata+"/data/ipythonrc-asap", userdir+"/ipythonrc-asap")
34 # commented out by TT on 2009.06.23 for casapy use
35 ##shutil.copyfile(asapdata+"/data/ipy_user_conf.py",
36 ## userdir+"/ipy_user_conf.py")
37 f = file(userdir+"/asapuserfuncs.py", "w")
38 f.close()
39 f = file(userdir+"/ipythonrc", "w")
40 f.close()
41# commented out by TT on 2009.06.23 for casapy use
42##else:
43 # upgrade to support later ipython versions
44 ##if not os.path.exists(userdir+"/ipy_user_conf.py"):
45 ## shutil.copyfile(asapdata+"/data/ipy_user_conf.py",
46 ## userdir+"/ipy_user_conf.py")
47
48# remove from namespace
49del asapdata, userdir, shutil, platform
50
51def _validate_bool(b):
52 'Convert b to a boolean or raise'
53 bl = b.lower()
54 if bl in ('f', 'no', 'false', '0', 0): return False
55 elif bl in ('t', 'yes', 'true', '1', 1): return True
56 else:
57 raise ValueError('Could not convert "%s" to boolean' % b)
58
59def _validate_int(s):
60 'convert s to int or raise'
61 try: return int(s)
62 except ValueError:
63 raise ValueError('Could not convert "%s" to int' % s)
64
65def _asap_fname():
66 """
67 Return the path to the rc file
68
69 Search order:
70
71 * current working dir
72 * environ var ASAPRC
73 * HOME/.asaprc
74
75 """
76
77 fname = os.path.join( os.getcwd(), '.asaprc')
78 if os.path.exists(fname): return fname
79
80 if os.environ.has_key('ASAPRC'):
81 path = os.environ['ASAPRC']
82 if os.path.exists(path):
83 fname = os.path.join(path, '.asaprc')
84 if os.path.exists(fname):
85 return fname
86
87 if os.environ.has_key('HOME'):
88 home = os.environ['HOME']
89 fname = os.path.join(home, '.asaprc')
90 if os.path.exists(fname):
91 return fname
92 return None
93
94
95defaultParams = {
96 # general
97 'verbose' : [True, _validate_bool],
98 'useplotter' : [True, _validate_bool],
99 'insitu' : [True, _validate_bool],
100
101 # plotting
102 'plotter.gui' : [True, _validate_bool],
103 'plotter.stacking' : ['p', str],
104 'plotter.panelling' : ['s', str],
105 'plotter.colours' : ['', str],
106 'plotter.linestyles' : ['', str],
107 'plotter.decimate' : [False, _validate_bool],
108 'plotter.ganged' : [True, _validate_bool],
109 'plotter.histogram' : [False, _validate_bool],
110 'plotter.papertype' : ['A4', str],
111 'plotter.xaxisformatting' : ['asap', str],
112
113 # scantable
114 'scantable.save' : ['ASAP', str],
115 'scantable.autoaverage' : [True, _validate_bool],
116 'scantable.freqframe' : ['LSRK', str], #default frequency frame
117 'scantable.verbosesummary' : [False, _validate_bool],
118 'scantable.storage' : ['memory', str],
119 'scantable.history' : [True, _validate_bool],
120 'scantable.reference' : ['.*(e|w|_R)$', str]
121 # fitter
122 }
123
124def list_rcparameters():
125
126 print """
127# general
128# print verbose output
129verbose : True
130
131# preload a default plotter
132useplotter : True
133
134# apply operations on the input scantable or return new one
135insitu : True
136
137# plotting
138
139# do we want a GUI or plot to a file
140plotter.gui : True
141
142# default mode for colour stacking
143plotter.stacking : Pol
144
145# default mode for panelling
146plotter.panelling : scan
147
148# push panels together, to share axislabels
149plotter.ganged : True
150
151# decimate the number of points plotted by a factor of
152# nchan/1024
153plotter.decimate : False
154
155# default colours/linestyles
156plotter.colours :
157plotter.linestyles :
158
159# enable/disable histogram plotting
160plotter.histogram : False
161
162# ps paper type
163plotter.papertype : A4
164
165# The formatting style of the xaxis
166plotter.xaxisformatting : 'asap' or 'mpl'
167
168# scantable
169
170# default storage of scantable ('memory'/'disk')
171scantable.storage : memory
172
173# write history of each call to scantable
174scantable.history : True
175
176# default ouput format when saving
177scantable.save : ASAP
178
179# auto averaging on read
180scantable.autoaverage : True
181
182# default frequency frame to set when function
183# scantable.set_freqframe is called
184scantable.freqframe : LSRK
185
186# Control the level of information printed by summary
187scantable.verbosesummary : False
188
189# Control the identification of reference (off) scans
190# This is has to be a regular expression
191scantable.reference : .*(e|w|_R)$
192# Fitter
193"""
194
195def rc_params():
196 'Return the default params updated from the values in the rc file'
197
198 fname = _asap_fname()
199
200 if fname is None or not os.path.exists(fname):
201 message = 'could not find rc file; returning defaults'
202 ret = dict([ (key, tup[0]) for key, tup in defaultParams.items()])
203 #print message
204 return ret
205
206 cnt = 0
207 for line in file(fname):
208 cnt +=1
209 line = line.strip()
210 if not len(line): continue
211 if line.startswith('#'): continue
212 tup = line.split(':',1)
213 if len(tup) !=2:
214 #print ('Illegal line #%d\n\t%s\n\tin file "%s"' % (cnt, line, fname))
215 casalog.post('Illegal line #%d\n\t%s\n\tin file "%s"' % (cnt, line, fname), 'WARN')
216 continue
217
218 key, val = tup
219 key = key.strip()
220 if not defaultParams.has_key(key):
221 #print ('Bad key "%s" on line %d in %s' % (key, cnt, fname))
222 casalog.post('Bad key "%s" on line %d in %s' % (key, cnt, fname), 'WARN')
223 continue
224
225 default, converter = defaultParams[key]
226
227 ind = val.find('#')
228 if ind>=0: val = val[:ind] # ignore trailing comments
229 val = val.strip()
230 try: cval = converter(val) # try to convert to proper type or raise
231 except ValueError, msg:
232 #print ('Bad val "%s" on line #%d\n\t"%s"\n\tin file "%s"\n\t%s' % (val, cnt, line, fname, msg))
233 casalog.post('Bad val "%s" on line #%d\n\t"%s"\n\tin file "%s"\n\t%s' % (val, cnt, line, fname, msg), 'WARN')
234 continue
235 else:
236 # Alles Klar, update dict
237 defaultParams[key][0] = cval
238
239 # strip the conveter funcs and return
240 ret = dict([ (key, tup[0]) for key, tup in defaultParams.items()])
241 print ('loaded rc file %s'%fname)
242
243 return ret
244
245
246# this is the instance used by the asap classes
247rcParams = rc_params()
248
249rcParamsDefault = dict(rcParams.items()) # a copy
250
251def rc(group, **kwargs):
252 """
253 Set the current rc params. Group is the grouping for the rc, eg
254 for scantable.save the group is 'scantable', for plotter.stacking, the
255 group is 'plotter', and so on. kwargs is a list of attribute
256 name/value pairs, eg
257
258 rc('scantable', save='SDFITS')
259
260 sets the current rc params and is equivalent to
261
262 rcParams['scantable.save'] = 'SDFITS'
263
264 Use rcdefaults to restore the default rc params after changes.
265 """
266
267 aliases = {}
268
269 for k,v in kwargs.items():
270 name = aliases.get(k) or k
271 if len(group):
272 key = '%s.%s' % (group, name)
273 else:
274 key = name
275 if not rcParams.has_key(key):
276 raise KeyError('Unrecognized key "%s" for group "%s" and name "%s"' % (key, group, name))
277
278 rcParams[key] = v
279
280
281def rcdefaults():
282 """
283 Restore the default rc params - the ones that were created at
284 asap load time
285 """
286 rcParams.update(rcParamsDefault)
287
288def _n_bools(n, val):
289 return [ val for i in xrange(n) ]
290
291def _is_sequence_or_number(param, ptype=int):
292 if isinstance(param,tuple) or isinstance(param,list):
293 if len(param) == 0: return True # empty list
294 out = True
295 for p in param:
296 out &= isinstance(p,ptype)
297 return out
298 elif isinstance(param, ptype):
299 return True
300 return False
301
302def _to_list(param, ptype=int):
303 if isinstance(param, ptype):
304 if ptype is str: return param.split()
305 else: return [param]
306 if _is_sequence_or_number(param, ptype):
307 return param
308 return None
309
310def unique(x):
311 """
312 Return the unique values in a list
313 Parameters:
314 x: the list to reduce
315 Examples:
316 x = [1,2,3,3,4]
317 print unique(x)
318 [1,2,3,4]
319 """
320 return dict([ (val, 1) for val in x]).keys()
321
322def list_files(path=".",suffix="rpf"):
323 """
324 Return a list files readable by asap, such as rpf, sdfits, mbf, asap
325 Parameters:
326 path: The directory to list (default '.')
327 suffix: The file extension (default rpf)
328 Example:
329 files = list_files("data/","sdfits")
330 print files
331 ['data/2001-09-01_0332_P363.sdfits',
332 'data/2003-04-04_131152_t0002.sdfits',
333 'data/Sgr_86p262_best_SPC.sdfits']
334 """
335 if not os.path.isdir(path):
336 return None
337 valid = "rpf rpf.1 rpf.2 sdf sdfits mbf asap".split()
338 if not suffix in valid:
339 return None
340 files = [os.path.expanduser(os.path.expandvars(path+"/"+f)) for f in os.listdir(path)]
341 return filter(lambda x: x.endswith(suffix),files)
342
343# workaround for ipython, which redirects this if banner=0 in ipythonrc
344sys.stdout = sys.__stdout__
345sys.stderr = sys.__stderr__
346
347# Logging
348from taskinit import *
349from asap._asap import Log as _asaplog
350global asaplog
351asaplog=_asaplog()
352if rcParams['verbose']:
353 asaplog.enable()
354else:
355 asaplog.disable()
356
357def print_log():
358 log = asaplog.pop()
359 #if len(log) and rcParams['verbose']: print log
360 if len(log) and rcParams['verbose']: casalog.post( log )
361 return
362
363def mask_and(a, b):
364 assert(len(a)==len(b))
365 return [ a[i] & b[i] for i in xrange(len(a)) ]
366
367def mask_or(a, b):
368 assert(len(a)==len(b))
369 return [ a[i] | b[i] for i in xrange(len(a)) ]
370
371def mask_not(a):
372 return [ not i for i in a ]
373
374from asapfitter import fitter
375from asapreader import reader
376from selector import selector
377
378from asapmath import *
379from scantable import scantable
380from asaplinefind import linefinder
381from linecatalog import linecatalog
382from interactivemask import interactivemask
383
384if rcParams['useplotter']:
385 try:
386 from asapplotter import asapplotter
387 gui = os.environ.has_key('DISPLAY') and rcParams['plotter.gui']
388 if gui:
389 import matplotlib
390 matplotlib.use("TkAgg")
391 import pylab
392 xyplotter = pylab
393 plotter = asapplotter(gui)
394 del gui
395 except ImportError:
396 #print "Matplotlib not installed. No plotting available"
397 casalog.post( "Matplotlib not installed. No plotting available", 'WARN' )
398
399__date__ = '$Date: 2009-08-05 07:48:43 +0000 (Wed, 05 Aug 2009) $'.split()[1]
400__version__ = '2.3.1 alma'
401# nrao casapy specific, get revision number
402#__revision__ = ' unknown '
403casapath=os.environ["CASAPATH"].split()
404revinfo=casapath[0]+'/'+casapath[1]+'/python/2.5/asap/svninfo.txt'
405if os.path.isfile(revinfo):
406 f = file(revinfo)
407 f.readline()
408 revsionno=f.readline()
409 f.close()
410 __revision__ = revsionno.rstrip()
411else:
412 __revision__ = ' unknown '
413
414def is_ipython():
415 return '__IP' in dir(sys.modules["__main__"])
416if is_ipython():
417 def version(): print "ASAP %s(%s)"% (__version__, __date__)
418 def list_scans(t = scantable):
419 import types
420 globs = sys.modules['__main__'].__dict__.iteritems()
421 print "The user created scantables are:"
422 sts = map(lambda x: x[0], filter(lambda x: isinstance(x[1], t), globs))
423 print filter(lambda x: not x.startswith('_'), sts)
424 return
425
426 def commands():
427 x = """
428 [The scan container]
429 scantable - a container for integrations/scans
430 (can open asap/rpfits/sdfits and ms files)
431 copy - returns a copy of a scan
432 get_scan - gets a specific scan out of a scantable
433 (by name or number)
434 drop_scan - drops a specific scan out of a scantable
435 (by number)
436 set_selection - set a new subselection of the data
437 get_selection - get the current selection object
438 summary - print info about the scantable contents
439 stats - get specified statistic of the spectra in
440 the scantable
441 stddev - get the standard deviation of the spectra
442 in the scantable
443 get_tsys - get the TSys
444 get_time - get the timestamps of the integrations
445 get_inttime - get the integration time
446 get_sourcename - get the source names of the scans
447 get_azimuth - get the azimuth of the scans
448 get_elevation - get the elevation of the scans
449 get_parangle - get the parallactic angle of the scans
450 get_unit - get the current unit
451 set_unit - set the abcissa unit to be used from this
452 point on
453 get_abcissa - get the abcissa values and name for a given
454 row (time)
455 get_column_names - get the names of the columns in the scantable
456 for use with selector.set_query
457 set_freqframe - set the frame info for the Spectral Axis
458 (e.g. 'LSRK')
459 set_doppler - set the doppler to be used from this point on
460 set_dirframe - set the frame for the direction on the sky
461 set_instrument - set the instrument name
462 set_feedtype - set the feed type
463 get_fluxunit - get the brightness flux unit
464 set_fluxunit - set the brightness flux unit
465 set_sourcetype - set the type of the source - source or reference
466 create_mask - return an mask in the current unit
467 for the given region. The specified regions
468 are NOT masked
469 get_restfreqs - get the current list of rest frequencies
470 set_restfreqs - set a list of rest frequencies
471 shift_refpix - shift the reference pixel of the IFs
472 set_spectrum - overwrite the spectrum for a given row
473 get_spectrum - retrieve the spectrum for a given
474 get_mask - retrieve the mask for a given
475 flag - flag selected channels in the data
476 lag_flag - flag specified frequency in the data
477 save - save the scantable to disk as either 'ASAP',
478 'SDFITS' or 'ASCII'
479 nbeam,nif,nchan,npol - the number of beams/IFs/Pols/Chans
480 nscan - the number of scans in the scantable
481 nrow - the number of spectra in the scantable
482 history - print the history of the scantable
483 get_fit - get a fit which has been stored witnh the data
484 average_time - return the (weighted) time average of a scan
485 or a list of scans
486 average_pol - average the polarisations together.
487 average_beam - average the beams together.
488 convert_pol - convert to a different polarisation type
489 auto_quotient - return the on/off quotient with
490 automatic detection of the on/off scans (closest
491 in time off is selected)
492 mx_quotient - Form a quotient using MX data (off beams)
493 scale, *, / - return a scan scaled by a given factor
494 add, +, - - return a scan with given value added
495 bin - return a scan with binned channels
496 resample - return a scan with resampled channels
497 smooth - return the spectrally smoothed scan
498 poly_baseline - fit a polynomial baseline to all Beams/IFs/Pols
499 auto_poly_baseline - automatically fit a polynomial baseline
500 recalc_azel - recalculate azimuth and elevation based on
501 the pointing
502 gain_el - apply gain-elevation correction
503 opacity - apply opacity correction
504 convert_flux - convert to and from Jy and Kelvin brightness
505 units
506 freq_align - align spectra in frequency frame
507 invert_phase - Invert the phase of the cross-correlation
508 swap_linears - Swap XX and YY (or RR LL)
509 rotate_xyphase - rotate XY phase of cross correlation
510 rotate_linpolphase - rotate the phase of the complex
511 polarization O=Q+iU correlation
512 freq_switch - perform frequency switching on the data
513 stats - Determine the specified statistic, e.g. 'min'
514 'max', 'rms' etc.
515 stddev - Determine the standard deviation of the current
516 beam/if/pol
517 [Selection]
518 selector - a selection object to set a subset of a scantable
519 set_scans - set (a list of) scans by index
520 set_cycles - set (a list of) cycles by index
521 set_beams - set (a list of) beamss by index
522 set_ifs - set (a list of) ifs by index
523 set_polarisations - set (a list of) polarisations by name
524 or by index
525 set_names - set a selection by name (wildcards allowed)
526 set_tsys - set a selection by tsys thresholds
527 set_query - set a selection by SQL-like query, e.g. BEAMNO==1
528 ( also get_ functions for all these )
529 reset - unset all selections
530 + - merge two selections
531
532 [Math] Mainly functions which operate on more than one scantable
533
534 average_time - return the (weighted) time average
535 of a list of scans
536 quotient - return the on/off quotient
537 simple_math - simple mathematical operations on two scantables,
538 'add', 'sub', 'mul', 'div'
539 quotient - build quotient of the given on and off scans
540 (matched pairs and 1 off - n on are valid)
541 merge - merge a list of scantables
542
543 [Line Catalog]
544 linecatalog - a linecatalog wrapper, taking an ASCII or
545 internal format table
546 summary - print a summary of the current selection
547 set_name - select a subset by name pattern, e.g. '*OH*'
548 set_strength_limits - select a subset by line strength limits
549 set_frequency_limits - select a subset by frequency limits
550 reset - unset all selections
551 save - save the current subset to a table (internal
552 format)
553 get_row - get the name and frequency from a specific
554 row in the table
555 [Fitting]
556 fitter
557 auto_fit - return a scan where the function is
558 applied to all Beams/IFs/Pols.
559 commit - return a new scan where the fits have been
560 commited.
561 fit - execute the actual fitting process
562 store_fit - store the fit parameters in the data (scantable)
563 get_chi2 - get the Chi^2
564 set_scan - set the scantable to be fit
565 set_function - set the fitting function
566 set_parameters - set the parameters for the function(s), and
567 set if they should be held fixed during fitting
568 set_gauss_parameters - same as above but specialised for individual
569 gaussian components
570 get_parameters - get the fitted parameters
571 plot - plot the resulting fit and/or components and
572 residual
573 [Plotter]
574 asapplotter - a plotter for asap, default plotter is
575 called 'plotter'
576 plot - plot a scantable
577 plot_lines - plot a linecatalog overlay
578 save - save the plot to a file ('png' ,'ps' or 'eps')
579 set_mode - set the state of the plotter, i.e.
580 what is to be plotted 'colour stacked'
581 and what 'panelled'
582 set_selection - only plot a selected part of the data
583 set_range - set a 'zoom' window [xmin,xmax,ymin,ymax]
584 set_legend - specify user labels for the legend indeces
585 set_title - specify user labels for the panel indeces
586 set_abcissa - specify a user label for the abcissa
587 set_ordinate - specify a user label for the ordinate
588 set_layout - specify the multi-panel layout (rows,cols)
589 set_colors - specify a set of colours to use
590 set_linestyles - specify a set of linestyles to use if only
591 using one color
592 set_font - set general font properties, e.g. 'family'
593 set_histogram - plot in historam style
594 set_mask - set a plotting mask for a specific polarization
595 text - draw text annotations either in data or relative
596 coordinates
597 arrow - draw arrow annotations either in data or relative
598 coordinates
599 axhline,axvline - draw horizontal/vertical lines
600 axhspan,axvspan - draw horizontal/vertical regions
601
602 xyplotter - matplotlib/pylab plotting functions
603
604 [Reading files]
605 reader - access rpfits/sdfits files
606 open - attach reader to a file
607 close - detach reader from file
608 read - read in integrations
609 summary - list info about all integrations
610
611 [General]
612 commands - this command
613 print - print details about a variable
614 list_scans - list all scantables created bt the user
615 list_files - list all files readable by asap (default rpf)
616 del - delete the given variable from memory
617 range - create a list of values, e.g.
618 range(3) = [0,1,2], range(2,5) = [2,3,4]
619 help - print help for one of the listed functions
620 execfile - execute an asap script, e.g. execfile('myscript')
621 list_rcparameters - print out a list of possible values to be
622 put into $HOME/.asaprc
623 rc - set rc parameters from within asap
624 mask_and,mask_or,
625 mask_not - boolean operations on masks created with
626 scantable.create_mask
627
628 Note:
629 How to use this with help:
630 # function 'summary'
631 [xxx] is just a category
632 Every 'sub-level' in this list should be replaces by a '.' Period when
633 using help
634 Example:
635 ASAP> help scantable # to get info on ths scantable
636 ASAP> help scantable.summary # to get help on the scantable's
637 ASAP> help average_time
638
639 """
640 if rcParams['verbose']:
641 try:
642 from IPython.genutils import page as pager
643 except ImportError:
644 from pydoc import pager
645 pager(x)
646 else:
647 print x
648 return
649
650def welcome():
651 return """Welcome to ASAP v%s (%s) - the ATNF Spectral Analysis Package
652
653Please report any bugs via:
654http://svn.atnf.csiro.au/trac/asap/simpleticket
655
656[IMPORTANT: ASAP is 0-based]
657Type commands() to get a list of all available ASAP commands.""" % (__version__, __date__)
Note: See TracBrowser for help on using the repository browser.