diff --git a/services/crawler/cli.go b/services/crawler/cli.go
index ed1bc6caf..82d47e41b 100644
--- a/services/crawler/cli.go
+++ b/services/crawler/cli.go
@@ -70,43 +70,21 @@ func RootCmd(c *cli.Context) error {
 
 	defer crawler.Close()
 
-	return nil
-
-	// streamer, err := NewEtheruemStreamer()
+	streamer, err := NewEtheruemStreamer()
 
-	// if err != nil {
-	// 	return err
-	// }
+	if err != nil {
+		return err
+	}
 
 	// for now use crawler's introspect and s3 client rather than recreating them
-	// streamer.Glue = crawler.Glue
-	// streamer.S3 = crawler.S3
-
-	// err = streamer.Stream()
-
-	// if err != nil {
-	// 	return err
-	// }
-}
-
-// func RootCmd(c *cli.Context) error {
-// 	crawler, err := NewCrawler()
+	streamer.Glue = crawler.Glue
+	streamer.S3 = crawler.S3
 
-// 	if err != nil {
-// 		return err
-// 	}
+	err = streamer.Stream()
 
-// 	_, err = crawler.Introspect()
-
-// 	if err != nil {
-// 		return err
-// 	}
-
-// 	err = crawler.Crawl()
-
-// 	if err != nil {
-// 		return err
-// 	}
+	if err != nil {
+		return err
+	}
 
-// 	return nil
-// }
+	return nil
+}
diff --git a/services/crawler/crawler.go b/services/crawler/crawler.go
index bf5133758..93e808c0c 100644
--- a/services/crawler/crawler.go
+++ b/services/crawler/crawler.go
@@ -175,7 +175,7 @@ func (c *EtheruemCrawler) Crawl() error {
 
 	l.Info("crawling %d blocks...\n", c.Head+1)
 
-	step := 500000
+	step := 250000
 
 	for i := int(c.Head); i >= 0; i -= step {
 		start := i
@@ -185,80 +185,33 @@ func (c *EtheruemCrawler) Crawl() error {
 			end = 0
 		}
 
-		go func(start, end int) {
-			defer func() {
-				c.Wg.Done()
-				<-c.Sema
-			}()
+		l.Info("batch=%d start=%d end=%d\n", i/step, start, end)
 
-			l.Info("batch=%d start=%d end=%d\n", i/step, start, end)
+		// go func(start, end int) {
+		// 	defer func() {
+		// 		c.Wg.Done()
+		// 		<-c.Sema
+		// 	}()
 
-			for j := start; j >= end; j-- {
-				events, err := c.ProcessBlock(int(j))
+		// 	l.Info("batch=%d start=%d end=%d\n", i/step, start, end)
 
-				if err != nil {
-					l.Error("error processing block=%d err=%s\n", j, err)
-				}
+		// 	for j := start; j >= end; j-- {
+		// 		events, err := c.ProcessBlock(int(j))
 
-				l.Info("captured %d events", len(events))
-				// ndjson, err := EncodeToNDJSONBytes(events)
+		// 		if err != nil {
+		// 			l.Error("error processing block=%d err=%s\n", j, err)
+		// 		}
 
-				// if err != nil {
-				// 	l.Error("error encoding events to ndjson err=%s\n", err)
-				// }
-			}
-		}(start, end)
+		// 		l.Info("captured %d events", len(events))
+		// 		// ndjson, err := EncodeToNDJSONBytes(events)
+
+		// 		// if err != nil {
+		// 		// 	l.Error("error encoding events to ndjson err=%s\n", err)
+		// 		// }
+		// 	}
+		// }(start, end)
 	}
 	return nil
-
-	// go func(start, end uint64) {
-	// 	defer func() {
-	// 		<-c.Sema
-	// 		c.Wg.Done()
-	// 	}()
-	// 	l.Info("batch=%d start=%d end=%d\n", i/step, start, end)
-
-	// 	for j := start; j <= end; j++ {
-	// 		events, err := c.ProcessBlock(int(j))
-
-	// 		if err != nil {
-	// 			l.Error("error processing block=%d err=%s\n", j, err)
-	// 			continue
-	// 		}
-
-	// 		ndjson, err := EncodeToNDJSONBytes(events)
-
-	// 		if err != nil {
-	// 			l.Error("error encoding events to ndjson err=%s\n", err)
-	// 			continue
-	// 		}
-
-	// 		// bucketPath := fmt.Sprintf("blocks/%d.ndjson", j)
-	// 		// tables := c.Glue.Tables
-	// 		// err = c.S3.UploadBytes(s)
-
-	// 		// save to local file
-	// 		fpath := fmt.Sprintf("data/%d-%d.ndjson", start, end)
-
-	// 		f, err := os.OpenFile(fpath, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0644)
-
-	// 		if err != nil {
-	// 			l.Error("error opening file=%s err=%s\n", fpath, err)
-	// 			continue
-	// 		}
-
-	// 		_, err = f.Write(ndjson)
-
-	// 		if err != nil {
-	// 			l.Error("error writing to file=%s err=%s\n", fpath, err)
-	// 			continue
-	// 		}
-
-	// 		c.Mutex.Lock()
-	// 		c.EventsConsumed++
-	// 		c.Mutex.Unlock()
-	// 	}
-	// }(start, end)
 }
 
 func (c *EtheruemCrawler) Introspect() (map[string]Table, error) {
@@ -313,11 +266,11 @@ func (c *EtheruemCrawler) Introspect() (map[string]Table, error) {
 			table.SerDe = *t.StorageDescriptor.SerdeInfo.Name
 		}
 
-		if strings.Contains(*t.Name, "_event_") {
+		if strings.Contains(*t.Name, "event") {
 			tables["events"] = table
 		} else if strings.Contains(*t.Name, "staking_action") {
 			tables["staking"] = table
-		} else if strings.Contains(*t.Name, "_wallet_") {
+		} else if strings.Contains(*t.Name, "wallet") {
 			tables["wallet"] = table
 		}
 	}
diff --git a/services/crawler/exchange.go b/services/crawler/exchange.go
new file mode 100644
index 000000000..5a081099f
--- /dev/null
+++ b/services/crawler/exchange.go
@@ -0,0 +1,279 @@
+package main
+
+import (
+	"encoding/json"
+	"errors"
+	"fmt"
+	"io"
+	"net/http"
+	"time"
+)
+
+type Currency string
+
+const (
+	USD Currency = "USD"
+)
+
+// Exchange is an interface for getting current and historical prices
+// for a given coin and currency. Supports multiple exchanges.
+type Exchange interface {
+	// CurrentPrice returns the current price of a coin
+	CurrentPrice(coin ChainType, currency Currency) (ExchangePrice, error)
+	// GetHistoricalPrice returns the price of a coin at a given time
+	HistoricalPrice(coin ChainType, currency Currency, received time.Time) (ExchangePrice, error)
+}
+
+type ExchangePrice struct {
+	Value    float64   `json:"price,omitempty"`
+	Currency string    `json:"currency,omitempty"`
+	Coin     string    `json:"coin,omitempty"`
+	Time     time.Time `json:"time,omitempty"`
+}
+
+type CryptoCompareExchange struct {
+	BaseUrl string
+	ApiKey  string
+	Version int
+}
+
+type CryptoCompareTickerResponse struct {
+	Data struct {
+		ETHUSD struct {
+			Type                          string  `json:"TYPE"`
+			Market                        string  `json:"MARKET"`
+			Instrument                    string  `json:"INSTRUMENT"`
+			Ccseq                         int     `json:"CCSEQ"`
+			Value                         float64 `json:"VALUE"`
+			ValueFlag                     string  `json:"VALUE_FLAG"`
+			ValueLastUpdateTs             int     `json:"VALUE_LAST_UPDATE_TS"`
+			ValueLastUpdateNs             int     `json:"VALUE_LAST_UPDATE_NS"`
+			LastUpdateQuantity            float64 `json:"LAST_UPDATE_QUANTITY"`
+			LastUpdateQuoteQuantity       float64 `json:"LAST_UPDATE_QUOTE_QUANTITY"`
+			LastUpdateCcseq               int     `json:"LAST_UPDATE_CCSEQ"`
+			CurrentHourVolume             float64 `json:"CURRENT_HOUR_VOLUME"`
+			CurrentHourQuoteVolume        float64 `json:"CURRENT_HOUR_QUOTE_VOLUME"`
+			CurrentHourOpen               float64 `json:"CURRENT_HOUR_OPEN"`
+			CurrentHourHigh               float64 `json:"CURRENT_HOUR_HIGH"`
+			CurrentHourLow                float64 `json:"CURRENT_HOUR_LOW"`
+			CurrentHourTotalIndexUpdates  int     `json:"CURRENT_HOUR_TOTAL_INDEX_UPDATES"`
+			CurrentHourChange             float64 `json:"CURRENT_HOUR_CHANGE"`
+			CurrentHourChangePercentage   float64 `json:"CURRENT_HOUR_CHANGE_PERCENTAGE"`
+			CurrentDayVolume              float64 `json:"CURRENT_DAY_VOLUME"`
+			CurrentDayQuoteVolume         float64 `json:"CURRENT_DAY_QUOTE_VOLUME"`
+			CurrentDayOpen                float64 `json:"CURRENT_DAY_OPEN"`
+			CurrentDayHigh                float64 `json:"CURRENT_DAY_HIGH"`
+			CurrentDayLow                 float64 `json:"CURRENT_DAY_LOW"`
+			CurrentDayTotalIndexUpdates   int     `json:"CURRENT_DAY_TOTAL_INDEX_UPDATES"`
+			CurrentDayChange              float64 `json:"CURRENT_DAY_CHANGE"`
+			CurrentDayChangePercentage    float64 `json:"CURRENT_DAY_CHANGE_PERCENTAGE"`
+			CurrentWeekVolume             float64 `json:"CURRENT_WEEK_VOLUME"`
+			CurrentWeekQuoteVolume        float64 `json:"CURRENT_WEEK_QUOTE_VOLUME"`
+			CurrentWeekOpen               float64 `json:"CURRENT_WEEK_OPEN"`
+			CurrentWeekHigh               float64 `json:"CURRENT_WEEK_HIGH"`
+			CurrentWeekLow                float64 `json:"CURRENT_WEEK_LOW"`
+			CurrentWeekTotalIndexUpdates  int     `json:"CURRENT_WEEK_TOTAL_INDEX_UPDATES"`
+			CurrentWeekChange             float64 `json:"CURRENT_WEEK_CHANGE"`
+			CurrentWeekChangePercentage   float64 `json:"CURRENT_WEEK_CHANGE_PERCENTAGE"`
+			CurrentMonthVolume            float64 `json:"CURRENT_MONTH_VOLUME"`
+			CurrentMonthQuoteVolume       float64 `json:"CURRENT_MONTH_QUOTE_VOLUME"`
+			CurrentMonthOpen              float64 `json:"CURRENT_MONTH_OPEN"`
+			CurrentMonthHigh              float64 `json:"CURRENT_MONTH_HIGH"`
+			CurrentMonthLow               float64 `json:"CURRENT_MONTH_LOW"`
+			CurrentMonthTotalIndexUpdates int     `json:"CURRENT_MONTH_TOTAL_INDEX_UPDATES"`
+			CurrentMonthChange            float64 `json:"CURRENT_MONTH_CHANGE"`
+			CurrentMonthChangePercentage  float64 `json:"CURRENT_MONTH_CHANGE_PERCENTAGE"`
+			CurrentYearVolume             float64 `json:"CURRENT_YEAR_VOLUME"`
+			CurrentYearQuoteVolume        float64 `json:"CURRENT_YEAR_QUOTE_VOLUME"`
+			CurrentYearOpen               float64 `json:"CURRENT_YEAR_OPEN"`
+			CurrentYearHigh               float64 `json:"CURRENT_YEAR_HIGH"`
+			CurrentYearLow                float64 `json:"CURRENT_YEAR_LOW"`
+			CurrentYearTotalIndexUpdates  int     `json:"CURRENT_YEAR_TOTAL_INDEX_UPDATES"`
+			CurrentYearChange             float64 `json:"CURRENT_YEAR_CHANGE"`
+			CurrentYearChangePercentage   float64 `json:"CURRENT_YEAR_CHANGE_PERCENTAGE"`
+			Moving24HourVolume            float64 `json:"MOVING_24_HOUR_VOLUME"`
+			Moving24HourQuoteVolume       float64 `json:"MOVING_24_HOUR_QUOTE_VOLUME"`
+			Moving24HourOpen              float64 `json:"MOVING_24_HOUR_OPEN"`
+			Moving24HourHigh              float64 `json:"MOVING_24_HOUR_HIGH"`
+			Moving24HourLow               float64 `json:"MOVING_24_HOUR_LOW"`
+			Moving24HourTotalIndexUpdates int     `json:"MOVING_24_HOUR_TOTAL_INDEX_UPDATES"`
+			Moving24HourChange            float64 `json:"MOVING_24_HOUR_CHANGE"`
+			Moving24HourChangePercentage  float64 `json:"MOVING_24_HOUR_CHANGE_PERCENTAGE"`
+			Moving7DayVolume              float64 `json:"MOVING_7_DAY_VOLUME"`
+			Moving7DayQuoteVolume         float64 `json:"MOVING_7_DAY_QUOTE_VOLUME"`
+			Moving7DayOpen                float64 `json:"MOVING_7_DAY_OPEN"`
+			Moving7DayHigh                float64 `json:"MOVING_7_DAY_HIGH"`
+			Moving7DayLow                 float64 `json:"MOVING_7_DAY_LOW"`
+			Moving7DayTotalIndexUpdates   int     `json:"MOVING_7_DAY_TOTAL_INDEX_UPDATES"`
+			Moving7DayChange              float64 `json:"MOVING_7_DAY_CHANGE"`
+			Moving7DayChangePercentage    float64 `json:"MOVING_7_DAY_CHANGE_PERCENTAGE"`
+			Moving30DayVolume             float64 `json:"MOVING_30_DAY_VOLUME"`
+			Moving30DayQuoteVolume        float64 `json:"MOVING_30_DAY_QUOTE_VOLUME"`
+			Moving30DayOpen               float64 `json:"MOVING_30_DAY_OPEN"`
+			Moving30DayHigh               float64 `json:"MOVING_30_DAY_HIGH"`
+			Moving30DayLow                float64 `json:"MOVING_30_DAY_LOW"`
+			Moving30DayTotalIndexUpdates  int     `json:"MOVING_30_DAY_TOTAL_INDEX_UPDATES"`
+			Moving30DayChange             float64 `json:"MOVING_30_DAY_CHANGE"`
+			Moving30DayChangePercentage   float64 `json:"MOVING_30_DAY_CHANGE_PERCENTAGE"`
+			Moving90DayVolume             float64 `json:"MOVING_90_DAY_VOLUME"`
+			Moving90DayQuoteVolume        float64 `json:"MOVING_90_DAY_QUOTE_VOLUME"`
+			Moving90DayOpen               float64 `json:"MOVING_90_DAY_OPEN"`
+			Moving90DayHigh               float64 `json:"MOVING_90_DAY_HIGH"`
+			Moving90DayLow                float64 `json:"MOVING_90_DAY_LOW"`
+			Moving90DayTotalIndexUpdates  int     `json:"MOVING_90_DAY_TOTAL_INDEX_UPDATES"`
+			Moving90DayChange             float64 `json:"MOVING_90_DAY_CHANGE"`
+			Moving90DayChangePercentage   float64 `json:"MOVING_90_DAY_CHANGE_PERCENTAGE"`
+			Moving180DayVolume            float64 `json:"MOVING_180_DAY_VOLUME"`
+			Moving180DayQuoteVolume       float64 `json:"MOVING_180_DAY_QUOTE_VOLUME"`
+			Moving180DayOpen              float64 `json:"MOVING_180_DAY_OPEN"`
+			Moving180DayHigh              float64 `json:"MOVING_180_DAY_HIGH"`
+			Moving180DayLow               float64 `json:"MOVING_180_DAY_LOW"`
+			Moving180DayTotalIndexUpdates int     `json:"MOVING_180_DAY_TOTAL_INDEX_UPDATES"`
+			Moving180DayChange            float64 `json:"MOVING_180_DAY_CHANGE"`
+			Moving180DayChangePercentage  float64 `json:"MOVING_180_DAY_CHANGE_PERCENTAGE"`
+			Moving365DayVolume            float64 `json:"MOVING_365_DAY_VOLUME"`
+			Moving365DayQuoteVolume       float64 `json:"MOVING_365_DAY_QUOTE_VOLUME"`
+			Moving365DayOpen              float64 `json:"MOVING_365_DAY_OPEN"`
+			Moving365DayHigh              float64 `json:"MOVING_365_DAY_HIGH"`
+			Moving365DayLow               float64 `json:"MOVING_365_DAY_LOW"`
+			Moving365DayTotalIndexUpdates int     `json:"MOVING_365_DAY_TOTAL_INDEX_UPDATES"`
+			Moving365DayChange            float64 `json:"MOVING_365_DAY_CHANGE"`
+			Moving365DayChangePercentage  float64 `json:"MOVING_365_DAY_CHANGE_PERCENTAGE"`
+			LifetimeFirstUpdateTs         int     `json:"LIFETIME_FIRST_UPDATE_TS"`
+			LifetimeVolume                float64 `json:"LIFETIME_VOLUME"`
+			LifetimeQuoteVolume           float64 `json:"LIFETIME_QUOTE_VOLUME"`
+			LifetimeOpen                  float64 `json:"LIFETIME_OPEN"`
+			LifetimeHigh                  float64 `json:"LIFETIME_HIGH"`
+			LifetimeHighTs                int     `json:"LIFETIME_HIGH_TS"`
+			LifetimeLow                   float64 `json:"LIFETIME_LOW"`
+			LifetimeLowTs                 int     `json:"LIFETIME_LOW_TS"`
+			LifetimeTotalIndexUpdates     int     `json:"LIFETIME_TOTAL_INDEX_UPDATES"`
+			LifetimeChange                float64 `json:"LIFETIME_CHANGE"`
+			LifetimeChangePercentage      float64 `json:"LIFETIME_CHANGE_PERCENTAGE"`
+		} `json:"ETH-USD"`
+	} `json:"Data"`
+	Err struct {
+	} `json:"Err"`
+}
+
+func NewHttpClientWithTimeout(time time.Duration) (*http.Client, error) {
+	client := &http.Client{
+		Timeout: time,
+	}
+	return client, nil
+}
+
+func NewCryptoCompareExchange(apiKey string) (Exchange, error) {
+
+	if apiKey == "" {
+		return nil, errors.New("api key is required")
+	}
+	return CryptoCompareExchange{
+		ApiKey:  apiKey,
+		BaseUrl: "https://data-api.cryptocompare.com", // v2 api
+	}, nil
+}
+
+func (c CryptoCompareExchange) CurrentPrice(coin ChainType, currency Currency) (ExchangePrice, error) {
+	price := ExchangePrice{
+		Coin:     coin.Short(),
+		Currency: currency.String(),
+		Time:     time.Now(),
+	}
+
+	httpClient, err := NewHttpClientWithTimeout(time.Duration(2 * time.Second))
+
+	if err != nil {
+		return price, err
+	}
+
+	path := "index/cc/v1/latest/tick"
+
+	url := fmt.Sprintf("%s/%s?market=ccix&instruments=%s-%s", c.BaseUrl, path, coin.Short(), currency.String())
+
+	req, err := httpClient.Get(url)
+
+	if err != nil {
+		return price, err
+	}
+
+	defer req.Body.Close()
+
+	res, err := io.ReadAll(req.Body)
+
+	if err != nil {
+		return price, err
+	}
+
+	var response CryptoCompareTickerResponse
+
+	err = json.Unmarshal(res, &response)
+
+	if err != nil {
+		return price, err
+	}
+
+	price.Value = response.Data.ETHUSD.CurrentDayOpen
+	return price, nil
+}
+
+func (c CryptoCompareExchange) HistoricalPrice(coin ChainType, currency Currency, received time.Time) (ExchangePrice, error) {
+	price := ExchangePrice{
+		Coin:     coin.Short(),
+		Currency: currency.String(),
+		Time:     received,
+	}
+
+	httpClient, err := NewHttpClientWithTimeout(time.Duration(2 * time.Second))
+
+	if err != nil {
+		return price, err
+	}
+
+	path := "index/cc/v1/historical/minutes"
+
+	// to_ts (timestamp) returns historical data before this unix timestamp
+	// use limit=2000 and keep going back in time using the to_ts param.
+	url := fmt.Sprintf("%s/%s?market=ccix&instruments=%s-%s&limit=20&to_ts=%d", c.BaseUrl, path, coin.Short(), currency.String(), received.Unix())
+
+	req, err := httpClient.Get(url)
+
+	if err != nil {
+		return price, err
+	}
+
+	defer req.Body.Close()
+
+	res, err := io.ReadAll(req.Body)
+
+	if err != nil {
+		return price, err
+	}
+
+	var response CryptoCompareTickerResponse
+
+	err = json.Unmarshal(res, &response)
+
+	if err != nil {
+		return price, err
+	}
+
+	price.Value = response.Data.ETHUSD.CurrentDayOpen
+	return price, nil
+}
+
+func (c ChainType) Short() string {
+	switch c {
+	case Ethereum:
+		return "ETH"
+	case Iotex:
+		return "IOTX"
+
+	default:
+		panic("invalid chain type")
+	}
+}
+
+func (c Currency) String() string {
+	return string(c)
+}
diff --git a/services/crawler/exchange_test.go b/services/crawler/exchange_test.go
new file mode 100644
index 000000000..8495aaa2d
--- /dev/null
+++ b/services/crawler/exchange_test.go
@@ -0,0 +1,31 @@
+package main
+
+import (
+	"os"
+	"testing"
+)
+
+func TestCurrentPrice(t *testing.T) {
+
+	var err error
+
+	err = LoadEnv()
+
+	if err != nil {
+		t.Error(err)
+	}
+
+	key := os.Getenv("CRYPTOCOMPARE_API_KEY")
+
+	exchange, err := NewCryptoCompareExchange(key)
+
+	if err != nil {
+		t.Error(err)
+	}
+
+	_, err = exchange.CurrentPrice(Ethereum, USD)
+
+	if err != nil {
+		t.Error(err)
+	}
+}