openquake.calculators.export package

Submodules

openquake.calculators.export.hazard module

class openquake.calculators.export.hazard.DisaggMatrix(poe, iml, dim_labels, matrix)

Bases: tuple

dim_labels

Alias for field number 2

iml

Alias for field number 1

matrix

Alias for field number 3

poe

Alias for field number 0

class openquake.calculators.export.hazard.GmfCollection(sitecol, imts, ruptures, investigation_time)[source]

Bases: object

Object converting the parameters

Parameters:
  • sitecol – SiteCollection
  • ruptures – ruptures
  • investigation_time – investigation time

into an object with the right form for the EventBasedGMFXMLWriter. Iterating over a GmfCollection yields GmfSet objects.

class openquake.calculators.export.hazard.GmfExporter(dstore)[source]

Bases: object

export_all()[source]
export_one(sm_id, eid)[source]
class openquake.calculators.export.hazard.GmfSet(gmfset, investigation_time, ses_idx)[source]

Bases: object

Small wrapper around the list of Gmf objects associated to the given SES.

class openquake.calculators.export.hazard.GroundMotionField(imt, sa_period, sa_damping, rupture_id, gmf_nodes)[source]

Bases: object

The Ground Motion Field generated by the given rupture

class openquake.calculators.export.hazard.GroundMotionFieldNode(gmv, loc)[source]

Bases: object

class openquake.calculators.export.hazard.HazardCurve(location, poes)

Bases: tuple

location

Alias for field number 0

poes

Alias for field number 1

class openquake.calculators.export.hazard.HazardMap(lon, lat, iml)

Bases: tuple

iml

Alias for field number 2

lat

Alias for field number 1

lon

Alias for field number 0

class openquake.calculators.export.hazard.Location(xy)[source]

Bases: object

class openquake.calculators.export.hazard.SES(ruptures, investigation_time, ordinal=1)[source]

Bases: object

Stochastic Event Set: A container for 1 or more ruptures associated with a specific investigation time span.

class openquake.calculators.export.hazard.SESCollection(idx_ses_dict, investigation_time=None)[source]

Bases: object

Stochastic Event Set Collection

class openquake.calculators.export.hazard.UHS(imls, location)

Bases: tuple

imls

Alias for field number 0

location

Alias for field number 1

openquake.calculators.export.hazard.add_imt(fname, imt)[source]
>>> add_imt('/path/to/hcurve_23.csv', 'SA(0.1)')
'/path/to/hcurve-SA(0.1)_23.csv'
openquake.calculators.export.hazard.build_etags(events)[source]

An array of tags for the underlying seismic events

openquake.calculators.export.hazard.convert_to_array(pmap, sitemesh, imtls)[source]

Convert the probability map into a composite array with header of the form PGA-0.1, PGA-0.2 ...

Parameters:
  • pmap – probability map
  • sitemesh – mesh of N sites
  • imtls – a DictArray with IMT and levels
Returns:

a composite array of lenght N

openquake.calculators.export.hazard.export_disagg_csv(ekey, dstore)[source]
openquake.calculators.export.hazard.export_disagg_xml(ekey, dstore)[source]
openquake.calculators.export.hazard.export_gmf(ekey, dstore)[source]
Parameters:
  • ekey – export key, i.e. a pair (datastore key, fmt)
  • dstore – datastore object
openquake.calculators.export.hazard.export_gmf_data_csv(ekey, dstore)[source]
openquake.calculators.export.hazard.export_gmf_scenario_npz(ekey, dstore)[source]
openquake.calculators.export.hazard.export_gmf_txt(key, dest, sitecol, imts, ruptures, rlz, investigation_time)[source]
Parameters:
  • key – output_type and export_type
  • dest – name of the exported file
  • sitecol – the full site collection
  • imts – the list of intensity measure types
  • ruptures – an ordered list of ruptures
  • rlz – a realization object
  • investigation_time – investigation time (None for scenario)
openquake.calculators.export.hazard.export_gmf_xml(key, dest, sitecol, imts, ruptures, rlz, investigation_time)[source]
Parameters:
  • key – output_type and export_type
  • dest – name of the exported file
  • sitecol – the full site collection
  • imts – the list of intensity measure types
  • ruptures – an ordered list of ruptures
  • rlz – a realization object
  • investigation_time – investigation time (None for scenario)
openquake.calculators.export.hazard.export_hazard_csv(key, dest, sitemesh, pmap, imtls, comment)[source]

Export the curves of the given realization into CSV.

Parameters:
  • key – output_type and export_type
  • dest – name of the exported file
  • sitemesh – site collection
  • pmap – a ProbabilityMap
  • imtls (dict) – intensity measure types and levels
  • comment – comment to use as header of the exported CSV file
openquake.calculators.export.hazard.export_hcurves_by_imt_csv(key, kind, rlzs_assoc, fname, sitecol, pmap, oq)[source]

Export the curves of the given realization into CSV.

Parameters:
  • key – output_type and export_type
  • kind – a string with the kind of output (realization or statistics)
  • rlzs_assoc – a openquake.commonlib.source.RlzsAssoc instance
  • fname – name of the exported file
  • sitecol – site collection
  • pmap – a probability map
  • oq – job.ini parameters
openquake.calculators.export.hazard.export_hcurves_csv(ekey, dstore)[source]

Exports the hazard curves into several .csv files

Parameters:
  • ekey – export key, i.e. a pair (datastore key, fmt)
  • dstore – datastore object
openquake.calculators.export.hazard.export_hcurves_npz(ekey, dstore)[source]
openquake.calculators.export.hazard.export_hcurves_xml_json(ekey, dstore)[source]
openquake.calculators.export.hazard.export_hmaps_npz(ekey, dstore)[source]
openquake.calculators.export.hazard.export_hmaps_xml_json(ekey, dstore)[source]
openquake.calculators.export.hazard.export_realizations(ekey, dstore)[source]
openquake.calculators.export.hazard.export_rup_data(ekey, dstore)[source]
openquake.calculators.export.hazard.export_ruptures_xml(ekey, dstore)[source]
Parameters:
  • ekey – export key, i.e. a pair (datastore key, fmt)
  • dstore – datastore object
openquake.calculators.export.hazard.export_ses_csv(ekey, dstore)[source]
Parameters:
  • ekey – export key, i.e. a pair (datastore key, fmt)
  • dstore – datastore object
openquake.calculators.export.hazard.export_uhs_npz(ekey, dstore)[source]
openquake.calculators.export.hazard.export_uhs_xml(ekey, dstore)[source]
openquake.calculators.export.hazard.get_mesh(sitecol, complete=True)[source]
openquake.calculators.export.hazard.get_metadata(realizations, kind)[source]
Parameters:
  • realizations (list) – realization objects
  • kind (str) – kind of data, i.e. a key in the datastore
Returns:

a dictionary with smlt_path, gsimlt_path, statistics, quantile_value

openquake.calculators.export.hazard.get_sm_id_eid(key)[source]

Extracts sm_id and eid from the export key.

>>> get_sm_id_eid('gmf:1:2')
['1', '2']
>>> get_sm_id_eid('gmf:3')
['0', '3']
>>> get_sm_id_eid('gmf')
[None, None]
openquake.calculators.export.hazard.hazard_curve_name(dstore, ekey, kind, rlzs_assoc)[source]
Parameters:
  • calc_id – the calculation ID
  • ekey – the export key
  • kind – the kind of key
  • rlzs_assoc – a RlzsAssoc instance
openquake.calculators.export.hazard.save_disagg_to_csv(metadata, matrices)[source]

Save disaggregation matrices to multiple .csv files.

openquake.calculators.export.risk module

class openquake.calculators.export.risk.AggCurve(losses, poes, average_loss, stddev_loss)

Bases: tuple

average_loss

Alias for field number 2

losses

Alias for field number 0

poes

Alias for field number 1

stddev_loss

Alias for field number 3

class openquake.calculators.export.risk.BcrData(location, asset_ref, average_annual_loss_original, average_annual_loss_retrofitted, bcr)

Bases: tuple

asset_ref

Alias for field number 1

average_annual_loss_original

Alias for field number 2

average_annual_loss_retrofitted

Alias for field number 3

bcr

Alias for field number 4

location

Alias for field number 0

class openquake.calculators.export.risk.Location(x, y)[source]

Bases: object

class openquake.calculators.export.risk.LossCurve(location, asset_ref, poes, losses, loss_ratios, average_loss, stddev_loss)

Bases: tuple

asset_ref

Alias for field number 1

average_loss

Alias for field number 5

location

Alias for field number 0

loss_ratios

Alias for field number 4

losses

Alias for field number 3

poes

Alias for field number 2

stddev_loss

Alias for field number 6

class openquake.calculators.export.risk.LossMap(location, asset_ref, value, std_dev)

Bases: tuple

asset_ref

Alias for field number 1

location

Alias for field number 0

std_dev

Alias for field number 3

value

Alias for field number 2

class openquake.calculators.export.risk.Output(ltype, path, array)

Bases: tuple

array

Alias for field number 2

ltype

Alias for field number 0

path

Alias for field number 1

openquake.calculators.export.risk.add_quotes(values)[source]
openquake.calculators.export.risk.build_damage_array(data, damage_dt)[source]
Parameters:
  • data – an array of length N with fields ‘mean’ and ‘stddev’
  • damage_dt – a damage composite data type loss_type -> states
Returns:

a composite array of length N and dtype damage_dt

openquake.calculators.export.risk.build_damage_dt(dstore)[source]
Parameters:dstore – a datastore instance
Returns:a composite dtype loss_type -> (mean_ds1, stdv_ds1, ...)
openquake.calculators.export.risk.copy_to(elt, rup_data, rupserials)[source]

Copy information from the rup_data dictionary into the elt array for the given rupture serials.

openquake.calculators.export.risk.export_agg_curve_rlzs(ekey, dstore)[source]
openquake.calculators.export.risk.export_agg_losses(ekey, dstore)[source]
Parameters:
  • ekey – export key, i.e. a pair (datastore key, fmt)
  • dstore – datastore object
openquake.calculators.export.risk.export_agg_losses_ebr(ekey, dstore)[source]
Parameters:
  • ekey – export key, i.e. a pair (datastore key, fmt)
  • dstore – datastore object
openquake.calculators.export.risk.export_agglosses(ekey, dstore)[source]
openquake.calculators.export.risk.export_all_loss_ratios(ekey, dstore)[source]
Parameters:
  • ekey – export key, i.e. a pair (datastore key, fmt)
  • dstore – datastore object
openquake.calculators.export.risk.export_all_losses_npz(ekey, dstore)[source]
openquake.calculators.export.risk.export_avg_losses(ekey, dstore)[source]
Parameters:
  • ekey – export key, i.e. a pair (datastore key, fmt)
  • dstore – datastore object
openquake.calculators.export.risk.export_bcr_map_rlzs(ekey, dstore)[source]
openquake.calculators.export.risk.export_csq_by_taxon_csv(ekey, dstore)[source]
openquake.calculators.export.risk.export_csq_total_csv(ekey, dstore)[source]
openquake.calculators.export.risk.export_damage(ekey, dstore)[source]
openquake.calculators.export.risk.export_damage_taxon(ekey, dstore)[source]
openquake.calculators.export.risk.export_damage_total(ekey, dstore)[source]
openquake.calculators.export.risk.export_dmg_by_asset_csv(ekey, dstore)[source]
openquake.calculators.export.risk.export_dmg_by_taxon_csv(ekey, dstore)[source]
openquake.calculators.export.risk.export_dmg_totalcsv(ekey, dstore)[source]
openquake.calculators.export.risk.export_dmg_xml(key, dstore, damage_states, dmg_data, lt, rlz)[source]

Export damage outputs in XML format.

Parameters:
  • key – dmg_dist_per_asset|dmg_dist_per_taxonomy|dmg_dist_total|collapse_map
  • dstore – the datastore
  • damage_states – the list of damage states
  • dmg_data – a list [(loss_type, unit, asset_ref, mean, stddev), ...]
  • lt – loss type string
  • rlz – a realization object
openquake.calculators.export.risk.export_loss_curves(ekey, dstore)[source]
openquake.calculators.export.risk.export_loss_curves_rlzs(ekey, dstore)[source]
openquake.calculators.export.risk.export_loss_curves_stats(ekey, dstore)[source]
openquake.calculators.export.risk.export_loss_map_xml_geojson(ekey, dstore)[source]
openquake.calculators.export.risk.export_loss_maps_csv(ekey, dstore)[source]
openquake.calculators.export.risk.export_loss_maps_rlzs_xml_geojson(ekey, dstore)[source]
openquake.calculators.export.risk.export_loss_maps_stats_xml_geojson(ekey, dstore)[source]
openquake.calculators.export.risk.export_losses_by_asset(ekey, dstore)[source]
Parameters:
  • ekey – export key, i.e. a pair (datastore key, fmt)
  • dstore – datastore object
openquake.calculators.export.risk.export_losses_by_taxon_csv(ekey, dstore)[source]
openquake.calculators.export.risk.export_rcurves(ekey, dstore)[source]
openquake.calculators.export.risk.export_rcurves_rlzs(ekey, dstore)[source]
openquake.calculators.export.risk.export_rlzs_by_asset_csv(ekey, dstore)[source]
openquake.calculators.export.risk.get_loss_maps(dstore, kind)[source]
Parameters:
  • dstore – a DataStore instance
  • kind – ‘rlzs’ or ‘stats’
openquake.calculators.export.risk.get_paths(rlz)[source]
Parameters:rlz – a logic tree realization (composite or simple)
Returns:a dict {‘source_model_tree_path’: string, ‘gsim_tree_path’: string}
openquake.calculators.export.risk.group_by_aid(data, loss_type)[source]
openquake.calculators.export.risk.indices(*sizes)[source]
openquake.calculators.export.risk.rup_data_dict(dstore, grp_ids, grp_trt)[source]

Extract a dictionary of arrays keyed by the rupture serial number from the datastore for the given source group IDs.

Module contents

exception openquake.calculators.export.MissingExporter[source]

Bases: exceptions.Exception

Raised when there is not exporter for the given pair (dskey, fmt)

openquake.calculators.export.export_csv(ekey, dstore)[source]

Default csv exporter for arrays stored in the output.hdf5 file

Parameters:
  • ekey – export key
  • dstore – datastore object
Returns:

a list with the path of the exported file

openquake.calculators.export.keyfunc(ekey)[source]

Extract the name before the colons:

>>> keyfunc(('agg_loss_table', 'csv'))
('agg_loss_table', 'csv')
>>> keyfunc(('agg_loss_table:1', 'csv'))
('agg_loss_table', 'csv')
>>> keyfunc(('agg_loss_table:1:0', 'csv'))
('agg_loss_table', 'csv')