# http://pyrocko.org - GPLv3
#
# The Pyrocko Developers, 21st Century
# ---|P------/S----------~Lg----------
import os.path as op
import math
from collections import defaultdict
import numpy as num
from pyrocko import util, config
from pyrocko import orthodrome as od
from pyrocko.guts_array import Array
from pyrocko.guts import Object, String
from .util import get_download_callback
PI = math.pi
[docs]class Plate(Object):
name = String.T(
help='Name of the tectonic plate.')
points = Array.T(
dtype=float, shape=(None, 2),
help='Points on the plate.')
def max_interpoint_distance(self):
p = od.latlon_to_xyz(self.points)
return math.sqrt(num.max(num.sum(
(p[num.newaxis, :, :] - p[:, num.newaxis, :])**2, axis=2)))
def contains_point(self, point):
return od.contains_point(self.points, point)
def contains_points(self, points):
return od.contains_points(self.points, points)
class Boundary(Object):
plate_name1 = String.T()
plate_name2 = String.T()
kind = String.T()
points = Array.T(dtype=float, shape=(None, 2))
cpoints = Array.T(dtype=float, shape=(None, 2))
itypes = Array.T(dtype=int, shape=(None))
def split_types(self, groups=None):
xyz = od.latlon_to_xyz(self.points)
xyzmid = (xyz[1:] + xyz[:-1, :]) * 0.5
cxyz = od.latlon_to_xyz(self.cpoints)
d = od.distances3d(xyzmid[num.newaxis, :, :], cxyz[:, num.newaxis, :])
idmin = num.argmin(d, axis=0)
itypes = self.itypes[idmin]
if groups is None:
groupmap = num.arange(len(self._index_to_type))
else:
d = {}
for igroup, group in enumerate(groups):
for name in group:
d[name] = igroup
groupmap = num.array(
[d[name] for name in self._index_to_type],
dtype=int)
iswitch = num.concatenate(
([0],
num.where(groupmap[itypes[1:]] != groupmap[itypes[:-1]])[0]+1,
[itypes.size]))
results = []
for ii in range(iswitch.size-1):
if groups is not None:
tt = [self._index_to_type[ityp] for ityp in num.unique(
itypes[iswitch[ii]:iswitch[ii+1]])]
else:
tt = self._index_to_type[itypes[iswitch[ii]]]
results.append((tt, self.points[iswitch[ii]:iswitch[ii+1]+1]))
return results
class Dataset(object):
def __init__(self, name, data_dir, citation):
self.name = name
self.citation = citation
self.data_dir = data_dir
def fpath(self, filename):
return op.join(self.data_dir, filename)
def download_file(
self, url, fpath, username=None, password=None,
status_callback=None):
util.download_file(
url, fpath, username, password, status_callback=status_callback)
class PlatesDataset(Dataset):
pass
[docs]class PeterBird2003(PlatesDataset):
'''
An updated digital model of plate boundaries.
'''
__citation = '''
Bird, Peter. "An updated digital model of plate boundaries." Geochemistry,
Geophysics, Geosystems 4.3 (2003).
'''
def __init__(
self,
name='PeterBird2003',
data_dir=None,
raw_data_url=('https://mirror.pyrocko.org/peterbird.name/oldFTP/PB2002/%s')): # noqa
if data_dir is None:
data_dir = op.join(config.config().tectonics_dir, name)
PlatesDataset.__init__(
self,
name,
data_dir=data_dir,
citation=self.__citation)
self.raw_data_url = raw_data_url
self.filenames = [
'2001GC000252_readme.txt',
'PB2002_boundaries.dig.txt',
'PB2002_orogens.dig.txt',
'PB2002_plates.dig.txt',
'PB2002_poles.dat.txt',
'PB2002_steps.dat.txt']
self._full_names = None
def full_name(self, name):
if not self._full_names:
fn = util.data_file(op.join('tectonics', 'bird2003_plates.txt'))
with open(fn, 'r') as f:
self._full_names = dict(
line.strip().split(None, 1) for line in f)
return self._full_names[name]
def download_if_needed(self):
for fn in self.filenames:
fpath = self.fpath(fn)
if not op.exists(fpath):
self.download_file(
self.raw_data_url % fn, fpath,
status_callback=get_download_callback(
'Downloading Bird 2003 plate database...'))
def get_boundaries(self):
self.download_if_needed()
fpath = self.fpath('PB2002_steps.dat.txt')
d = defaultdict(list)
ntyp = 0
type_to_index = {}
index_to_type = []
with open(fpath, 'rb') as f:
data = []
for line in f:
lsplit = line.split()
name = lsplit[1].lstrip(b':').decode('ascii')
plate_name1 = str(name[0:2])
plate_name2 = str(name[3:5])
kind = name[2]
alon, alat, blon, blat = list(map(float, lsplit[2:6]))
mlat = (alat + blat) * 0.5
dlon = ((blon - alon) + 180.) % 360. - 180.
mlon = alon + dlon * 0.5
typ = str(lsplit[14].strip(b':*').decode('ascii'))
if typ not in type_to_index:
ntyp += 1
type_to_index[typ] = ntyp - 1
index_to_type.append(typ)
ityp = type_to_index[typ]
d[plate_name1, kind, plate_name2].append((mlat, mlon, ityp))
d2 = {}
for k in d:
d2[k] = (
num.array([x[:2] for x in d[k]], dtype=float),
num.array([x[2] for x in d[k]], dtype=int))
fpath = self.fpath('PB2002_boundaries.dig.txt')
boundaries = []
plate_name1 = ''
plate_name2 = ''
kind = '-'
with open(fpath, 'rb') as f:
data = []
for line in f:
if line.startswith(b'***'):
cpoints, itypes = d2[plate_name1, kind, plate_name2]
boundaries.append(Boundary(
plate_name1=plate_name1,
plate_name2=plate_name2,
kind=kind,
points=num.array(data, dtype=float),
cpoints=cpoints,
itypes=itypes))
boundaries[-1]._type_to_index = type_to_index
boundaries[-1]._index_to_type = index_to_type
data = []
elif line.startswith(b' '):
data.append(list(map(float, line.split(b',')))[::-1])
else:
s = line.strip().decode('ascii')
plate_name1 = str(s[0:2])
plate_name2 = str(s[3:5])
kind = s[2]
return boundaries
def get_plates(self):
self.download_if_needed()
fpath = self.fpath('PB2002_plates.dig.txt')
plates = []
name = ''
with open(fpath, 'rb') as f:
data = []
for line in f:
if line.startswith(b'***'):
plates.append(Plate(
name=name,
points=num.array(data, dtype=float)))
data = []
elif line.startswith(b' '):
data.append(list(map(float, line.split(b',')))[::-1])
else:
name = str(line.strip().decode('ascii'))
return plates
class StrainRateDataset(Dataset):
pass
[docs]class GSRM1(StrainRateDataset):
'''
Global Strain Rate Map. An integrated global model of present-day
plate motions and plate boundary deformation'''
__citation = '''Kreemer, C., W.E. Holt, and A.J. Haines, "An integrated
global model of present-day plate motions and plate boundary deformation",
Geophys. J. Int., 154, 8-34, 2003.
'''
def __init__(
self,
name='GSRM1.2',
data_dir=None,
raw_data_url=('https://mirror.pyrocko.org/gsrm.unavco.org/model'
'/files/1.2/%s')):
if data_dir is None:
data_dir = op.join(config.config().tectonics_dir, name)
StrainRateDataset.__init__(
self,
name,
data_dir=data_dir,
citation=self.__citation)
self.raw_data_url = raw_data_url
self._full_names = None
self._names = None
def full_names(self):
if not self._full_names:
fn = util.data_file(op.join('tectonics', 'gsrm1_plates.txt'))
with open(fn, 'r') as f:
self._full_names = dict(
line.strip().split(None, 1) for line in f)
return self._full_names
def full_name(self, name):
name = self.plate_alt_names().get(name, name)
return self.full_names()[name]
def plate_names(self):
if self._names is None:
self._names = sorted(self.full_names().keys())
return self._names
def plate_alt_names(self):
# 'African Plate' is named 'Nubian Plate' in GSRM1
return {'AF': 'NU'}
def download_if_needed(self, fn):
fpath = self.fpath(fn)
if not op.exists(fpath):
self.download_file(
self.raw_data_url % fn, fpath,
status_callback=get_download_callback(
'Downloading global strain rate map...'))
def get_velocities(self, reference_name=None, region=None):
reference_name = self.plate_alt_names().get(
reference_name, reference_name)
if reference_name is None:
reference_name = 'NNR'
fn = 'velocity_%s.dat' % reference_name
self.download_if_needed(fn)
fpath = self.fpath(fn)
data = []
with open(fpath, 'rb') as f:
for line in f:
if line.strip().startswith(b'#'):
continue
t = line.split()
data.append(list(map(float, t)))
arr = num.array(data, dtype=float)
if region is not None:
points = arr[:, 1::-1]
mask = od.points_in_region(points, region)
arr = arr[mask, :]
lons, lats, veast, vnorth, veast_err, vnorth_err, corr = arr.T
return lats, lons, vnorth, veast, vnorth_err, veast_err, corr
__all__ = '''
GSRM1
PeterBird2003
Plate'''.split()
