Query RSAM

# See all available network/station/channel combinations
curl "https://avert.ldeo.columbia.edu/api/seismic/sites"

# See the most recent date available per channel
curl "https://avert.ldeo.columbia.edu/api/seismic/rsam/latest"

# Check which dates have data for AV.CLNE.BHZ
curl "https://avert.ldeo.columbia.edu/api/seismic/dates?\
network=AV&\
station=CLNE&\
channel=BHZ"

# RSAM for AV.CLNE.BHZ on April 10, 2026
curl "https://avert.ldeo.columbia.edu/api/seismic/rsam?\
network=AV&\
station=CLNE&\
channel=BHZ&\
datefrom=20260410&\
dateto=20260410"

# RSAM for three days
curl "https://avert.ldeo.columbia.edu/api/seismic/rsam?\
network=AV&\
station=CLNE&\
channel=BHZ&\
datefrom=20260410&\
dateto=20260412"

# RSAM for all of April 2026
curl "https://avert.ldeo.columbia.edu/api/seismic/rsam?\
network=AV&\
station=CLES&\
channel=BHZ&\
datefrom=20260401&\
dateto=20260430"

// Step 1: find available channels
const sitesRes = await fetch(
  'https://avert.ldeo.columbia.edu/api/seismic/sites'
);
const { channels } = await sitesRes.json();
console.log('Available channels:', channels.length);

// Step 2: query RSAM for the first channel
const { network, station, channel } = channels[0];
const params = new URLSearchParams({
  network, station, channel,
  datefrom: '20260410',
  dateto: '20260412',
});

const rsamRes = await fetch(
  `https://avert.ldeo.columbia.edu/api/seismic/rsam?${params}`
);
const data = await rsamRes.json();

const series = data.series[0];
console.log(`${series.points.length} points for ${network}.${station}.${channel}`);

// Fetch and plot RSAM data
async function getRsamSeries(network, station, channel, datefrom, dateto) {
  const params = new URLSearchParams({ network, station, channel, datefrom, dateto });
  const res = await fetch(
    `https://avert.ldeo.columbia.edu/api/seismic/rsam?${params}`
  );
  const data = await res.json();
  return data.series[0].points;
}

const points = await getRsamSeries('AV', 'CLNE', 'BHZ', '20260410', '20260412');

// points is an array of { time, rsam_counts }
const timestamps = points.map(p => new Date(p.time));
const values     = points.map(p => p.rsam_counts);

// Pass timestamps/values to your charting library

// Build a status dashboard showing latest RSAM date per channel
const res = await fetch(
  'https://avert.ldeo.columbia.edu/api/seismic/rsam/latest'
);
const { channels } = await res.json();

channels.forEach(({ network, station, channel, latest_date }) => {
  console.log(`${network}.${station}.${channel} — latest: ${latest_date}`);
});

import requests

response = requests.get(
    'https://avert.ldeo.columbia.edu/api/seismic/rsam',
    params={
        'network': 'AV',
        'station': 'CLNE',
        'channel': 'BHZ',
        'datefrom': '20260410',
        'dateto': '20260412',
    }
)
data = response.json()

series = data['series'][0]
print(f"{len(series['points'])} RSAM points")
print(f"Window: {series['window_sec']} seconds")

for point in series['points'][:5]:
    print(f"  {point['time']}: {point['rsam_counts']:.1f} counts")

import requests

# List all channels
sites = requests.get(
    'https://avert.ldeo.columbia.edu/api/seismic/sites'
).json()

for ch in sites['channels']:
    print(f"{ch['network']}.{ch['station']}.{ch['channel']}")

import requests

# Check which dates have data before querying
dates_res = requests.get(
    'https://avert.ldeo.columbia.edu/api/seismic/dates',
    params={'network': 'AV', 'station': 'CLNE', 'channel': 'BHZ'}
)
dates = dates_res.json()['dates']

print(f"Available dates: {len(dates)}")
print(f"Latest: {dates[0]}")
print(f"Oldest: {dates[-1]}")

import requests
import csv

response = requests.get(
    'https://avert.ldeo.columbia.edu/api/seismic/rsam',
    params={
        'network': 'AV',
        'station': 'CLNE',
        'channel': 'BHZ',
        'datefrom': '20260410',
        'dateto': '20260410',
    }
)
series = response.json()['series'][0]

with open('rsam.csv', 'w', newline='') as f:
    writer = csv.DictWriter(f, fieldnames=['time', 'rsam_counts'])
    writer.writeheader()
    writer.writerows(series['points'])

print(f"Exported {len(series['points'])} rows to rsam.csv")

import requests
import time

def query_rsam_with_retry(params, max_retries=3):
    for attempt in range(max_retries):
        response = requests.get(
            'https://avert.ldeo.columbia.edu/api/seismic/rsam',
            params=params
        )
        if response.status_code == 200:
            return response.json()
        elif response.status_code == 429:
            wait_time = 2 ** attempt
            print(f"Rate limited. Waiting {wait_time} seconds...")
            time.sleep(wait_time)
        else:
            response.raise_for_status()
    raise Exception("Max retries exceeded")

async function queryRsamWithRetry(params, maxRetries = 3) {
  const url = 'https://avert.ldeo.columbia.edu/api/seismic/rsam?' +
    new URLSearchParams(params);

  for (let attempt = 0; attempt < maxRetries; attempt++) {
    const response = await fetch(url);

    if (response.ok) return await response.json();

    if (response.status === 429) {
      const waitTime = Math.pow(2, attempt) * 1000;
      console.log(`Rate limited. Waiting ${waitTime / 1000} seconds...`);
      await new Promise(resolve => setTimeout(resolve, waitTime));
    } else {
      throw new Error(`HTTP ${response.status}: ${response.statusText}`);
    }
  }
  throw new Error('Max retries exceeded');
}