CloudflareワーカーとのRedis@Edge

次に、日付を引数として取り、分析データを返す簡単なコマンドラインアプリケーションを作成しましょう。フォルダを作成し、npm initを実行します 。次に、npm install ioredisを使用してRedisクライアントをインストールします 。 .env.exampleをコピーします .envとして ファイルを作成し、Redis URL（ioredis）を設定します。 index.jsを以下で更新します：

const Redis = require("ioredis");
require("dotenv").config();
console.log("EDGE analytics with CloudFlare Workers and Upstash Redis.");
let redis = new Redis(process.env.REDIS_URL);
let dateArg = process.argv[2];
let datestr;
if (dateArg) {
  datestr = dateArg;
} else {
  let d = new Date();
  datestr = d.getFullYear() + "-" + (d.getMonth() + 1) + "-" + d.getDate();
}

redis.lrange(datestr, "0", "-1", function (err, result) {
  let pageview = 0;
  let users = new Set();
  let countries = new Map();
  let paths = new Map();
  if (err) {
    console.log("Could not connect to Redis.");
    console.error(err);
  } else {
    console.log(
      "Upstash Redis Connection Successful. Analyzing the access logs..."
    );
    if (!result || result.length === 0) {
      console.log("Could not find any access logs for the date:" + datestr);
    } else {
      for (const elem of result) {
        let entries = JSON.parse(elem);
        for (let entry of entries) {
          if (entry[0] === "accept") {
            if (entry[1].startsWith("text")) pageview++;
          }
          if (entry[0] === "cf-ipcountry") {
            let temp = countries.get(entry[1]);
            if (!temp) {
              temp = 0;
            }
            countries.set(entry[1], temp + 1);
          }
          if (entry[0] === "url") {
            let temp = paths.get(entry[1]);
            if (!temp) {
              temp = 0;
            }
            paths.set(entry[1], temp + 1);
          }
          if (entry[0] === "x-real-ip") {
            users.add(entry[1]);
          }
        }
      }
      countries = new Map([...countries.entries()].sort((a, b) => b[1] - a[1]));
      paths = new Map([...paths.entries()].sort((a, b) => b[1] - a[1]));
      console.log("\nDATE: " + datestr);
      console.log("\nPAGE VIEWS: " + pageview);
      console.log("\nUNIQUE VISITORS: " + users.size);
      logMap("TOP COUNTRIES", countries);
      logMap("TOP PAGES", paths);
    }
  }
});

function logMap(title, data) {
  console.log("\n" + title);
  console.log("----------------");
  console.log(mapEntriesToString(data));
}

function mapEntriesToString(entries) {
  return Array.from(entries, ([k, v]) => `${k} : ${v}\n`).join("");
}

これで、node index 2021-6-16を使用してアプリケーションを実行できます。 または単にnode index 。後者は今日クエリします。

この例は出発点と考えることができます。分析のニーズに応じて、チャートとテーブルを備えたリッチWebアプリケーションを開発できます。他のRedisデータ構造を使用して、より強力な分析を行うことができます。

UpstashEdgeロードマップ

REST APIは、Edgeストーリーの最初のステップです。今年は2つの重要な開発を計画しています。

• エッジキャッシング:(更新：これはリリースされています。詳細をご覧ください）現在、すべてのRESTリクエストはデータベースリージョンに送信されます。間もなくエッジキャッシングがサポートされるため、RESTリクエストはグローバルなすべてのエッジロケーションにキャッシュされます。これにより、UpstashRedisはCloudflareKVのように世界中で低レイテンシを提供できるようになります。
• グローバルレプリケートデータベース:(更新：これはリリースされています。詳細）グローバル（マルチリージョン）レプリケーションは、データを複数のリージョンにレプリケートします。したがって、すべてのリクエスト（RedisとREST APIの両方）は最も近い場所に送信されます。これにより、一貫性の犠牲を最小限に抑えながら、グローバルに低レイテンシを実現できます。

Edgeロードマップ専用のブログ投稿を書く予定です。しばらくお待ちください。Twitterでフォローしてください。