|
10 | 10 |
|
11 | 11 | import os |
12 | 12 | from datetime import datetime |
| 13 | + |
13 | 14 | from importlib.metadata import version |
14 | 15 | import numpy as np |
15 | 16 | import healpy as hp |
@@ -253,118 +254,93 @@ def read_dndz(file_path): |
253 | 254 |
|
254 | 255 | Returns |
255 | 256 | ------- |
256 | | - list : |
| 257 | + np.array |
257 | 258 | redshift bin centers |
258 | | - list : |
| 259 | + np.array |
259 | 260 | number densities |
260 | | - list : |
261 | | - redshift bin edges |
| 261 | + np.array |
| 262 | + redshift bin edges; one less than centers and density arrays |
262 | 263 |
|
263 | 264 | """ |
264 | | - dat = ascii.read(file_path, format="commented_header") |
| 265 | + try: |
| 266 | + # Expecting header line "# z dn_dz" |
| 267 | + dat = ascii.read(file_path, format="commented_header") |
| 268 | + missing = [col for col in ("z", "dn_dz") if col not in dat.dtype.names] |
| 269 | + if missing: |
| 270 | + raise ValueError( |
| 271 | + f"Missing columns in dndz path {file_path}: {missing}" |
| 272 | + ) |
| 273 | + except: |
| 274 | + # No header line |
| 275 | + dat = ascii.read(file_path) |
| 276 | + dat.rename_column("col1", "z") |
| 277 | + dat.rename_column("col2", "dn_dz") |
| 278 | + |
| 279 | + # Remove last n(z) value which should be zero, to match bin centers |
| 280 | + tolerance = 1e-5 |
| 281 | + if dat["dn_dz"][-1] / sum(dat["dn_dz"]) > tolerance: |
| 282 | + raise ValueError("dn_dz at last z-edge = {dat['dn_dz'][-1]}, no zero") |
265 | 283 |
|
266 | | - # Remove last n(z) value which is zero, to match bin centers |
267 | 284 | nz = dat["dn_dz"][:-1] |
268 | 285 | z_edges = dat["z"] |
| 286 | + |
269 | 287 | z_centers = bin_edges2centers(z_edges) |
270 | 288 |
|
271 | 289 | return z_centers, nz, z_edges |
272 | 290 |
|
273 | 291 |
|
274 | | -def read_hp_mask(input_name, verbose=False): |
| 292 | +def read_hp_mask(input_path, verbose=False): |
275 | 293 | """Read Hp Mask. |
276 | 294 |
|
277 | | - Read healpy mask. |
| 295 | + Read healpix mask FITS file. |
278 | 296 |
|
279 | | - Parameters |
280 | | - ---------- |
281 | | - input_name : str |
282 | | - input file name |
283 | | - verbose : bool, optional |
284 | | - verbose output if ``True``;; default is ``False`` |
| 297 | + Parameters |
| 298 | + ---------- |
| 299 | + input_path : str |
| 300 | + input file path |
| 301 | + verbose : bool, optional |
| 302 | + verbose output if ``True``; default is ``False`` |
285 | 303 |
|
286 | | - Returns |
287 | | - ------- |
288 | | - array |
289 | | - mask values |
290 | | - bool |
291 | | - nest value (always ``False``) |
292 | | - int |
293 | | - nside |
| 304 | + Returns |
| 305 | + ------- |
| 306 | + array |
| 307 | + mask information |
| 308 | + bool |
| 309 | + NEST (RING) ordering if ``True`` (``False``) |
| 310 | + int |
| 311 | + nside |
294 | 312 |
|
295 | 313 | """ |
296 | 314 | if verbose: |
297 | | - print(f'Reading mask {input_name}...') |
| 315 | + print(f"Reading mask {input_path}...") |
298 | 316 |
|
299 | 317 | nest = False |
300 | 318 |
|
301 | | - # Open input mask |
302 | | - mask, header= hp.read_map( |
303 | | - input_name, |
| 319 | + # Open input mask |
| 320 | + mask, header = hp.read_map( |
| 321 | + input_path, |
304 | 322 | h=True, |
305 | 323 | nest=nest, |
306 | 324 | ) |
307 | | - for (key, value) in header: |
308 | | - if key == 'ORDERING': |
309 | | - if value == 'RING': |
| 325 | + for key, value in header: |
| 326 | + if key == "ORDERING": |
| 327 | + if value == "RING": |
310 | 328 | if nest: |
311 | 329 | raise ValueError( |
312 | | - 'input mask has ORDENING=RING, set nest to False' |
| 330 | + "input mask has ORDENING=RING, set nest to False" |
313 | 331 | ) |
314 | | - elif value == 'NEST': |
| 332 | + elif value == "NEST": |
315 | 333 | if not nest: |
316 | 334 | raise ValueError( |
317 | | - 'input mask has ORDENING=NEST, set nest to True' |
| 335 | + "input mask has ORDENING=NEST, set nest to True" |
318 | 336 | ) |
319 | 337 |
|
320 | | - # Get nside from header |
| 338 | + # Get nside from header |
321 | 339 | nside = None |
322 | 340 | for key, value in header: |
323 | | - if key == 'NSIDE': |
| 341 | + if key == "NSIDE": |
324 | 342 | nside = int(value) |
325 | 343 | if not nside: |
326 | | - raise KeyError('NSIDE not found in FITS mask header') |
| 344 | + raise KeyError("NSIDE not found in FITS mask header") |
327 | 345 |
|
328 | 346 | return mask, nest, nside |
329 | | - |
330 | | - |
331 | | -def get_binned_area(ra, dec, nside=512, return_pix=False): |
332 | | - """Get Binned Area. |
333 | | - |
334 | | - Return sky area corresponding to occupied pixels of binned catalogue. |
335 | | -
|
336 | | - Parameters |
337 | | - ---------- |
338 | | - ra : np.ndarray |
339 | | - Right Ascension coordinates |
340 | | - dec : np.ndarray |
341 | | - Declination coordinates |
342 | | - nside : int, optional |
343 | | - nside for binning; default is 512 |
344 | | - return_pix: bool, optional |
345 | | - return valid pixel list if ``True``; default is ``False`` |
346 | | - |
347 | | - Returns |
348 | | - ------- |
349 | | - float |
350 | | - area in square degrees |
351 | | - list |
352 | | - pixels of input data positions |
353 | | - |
354 | | - """ |
355 | | - # Pixel list of input data |
356 | | - pix = hp.ang2pix(nside, ra, dec, lonlat=True) |
357 | | - |
358 | | - # Number of occupied pixels |
359 | | - Nocc = np.unique(pix).size |
360 | | - |
361 | | - # Pixel area in square degrees |
362 | | - pix_area_deg2 = hp.nside2pixarea(nside, degrees=True) |
363 | | - |
364 | | - # Footprint area in square degrees |
365 | | - area_deg2 = Nocc * pix_area_deg2 |
366 | | - |
367 | | - if return_pix: |
368 | | - return area_deg2, pix |
369 | | - else: |
370 | | - return area_deg2 |
0 commit comments