IntentD 接入与数据格式

# 控制台 → 扩展 → SDK → 下载
# intentd-<name>.min.js 文件已包含您的密钥和配置。
cp ~/Downloads/intentd-my-extension.min.js ./extension/intentd.min.js

// background.js —— 第一行，顶层作用域。
// init 会自动调用；监听器必须在 service worker 启动时注册，
// 否则 Manifest V3 不会投递事件。
import './intentd.min.js';

// 可选：查询状态与手动发送。
// const status = await IntentD.status();
// await IntentD.flush();

import pandas as pd

# S3 中某个租户的日分区。
path = "s3://intentd-delivery/year=2026/month=09/day=11/tenant=ext_acme__7c0e.parquet.lz4"

frame = pd.read_parquet(
    path,
    columns=["timestamp", "domain", "search_query", "geo_country"],
    storage_options={
        "key": "YOUR_ACCESS_KEY",
        "secret": "YOUR_SECRET_KEY",
    },
)

top_domains = frame.groupby("domain").size().sort_values(ascending=False).head(20)
print(top_domains)

package main

import (
    "context"
    "log"

    "github.com/aws/aws-sdk-go-v2/config"
    "github.com/aws/aws-sdk-go-v2/service/s3"
)

func main() {
    ctx := context.Background()

    cfg, err := config.LoadDefaultConfig(ctx)
    if err != nil {
        log.Fatal(err)
    }

    client := s3.NewFromConfig(cfg)

    object, err := client.GetObject(ctx, &s3.GetObjectInput{
        Bucket: ptr("intentd-delivery"),
        Key:    ptr("year=2026/month=09/day=11/tenant=ext_acme__7c0e.parquet.lz4"),
    })
    if err != nil {
        log.Fatal(err)
    }
    defer object.Body.Close()

    // 之后用任意 Parquet 读取库即可，例如 parquet-go。
    log.Printf("已接收 %d 字节", *object.ContentLength)
}

func ptr(s string) *string { return &s }