2 数据流程

sRTA 平台支持两种角色的数据上传和使用模式：

客户模式：将自有数据上传到 sRTA 平台，sRTA 在每次广告决策时通过 Lua 脚本引用客户数据，实现广告决策干预。

服务商模式：将自有数据上传到 sRTA 平台，通过授权机制授权给客户使用，帮助客户提升广告效果。

整体过程可描述为：账号申请-->数据生产-->数据写入-->脚本编写-->脚本测试-->脚本上线-->效果验证

2.1 写入流程简述

本示例演示如何通过 sRTA 平台实现根据用户设备ID的安装状态决策拉活拉新，并根据活跃用户级别调节竞争力系数。

客户拥有最为全面准确的已安装状态及价值数据，该类信息需要客户上传。

示例用户

用户ID	已安装态	用户级别
张三	已安装	低价值
李四	已安装	中价值
王五	已安装	高价值
其他	未安装	--

策略： acitve=拉活，new=拉新

逻辑：

拉活广告：未安装用户不出。低价值用户降权、中等价值用户维持、高价值用户提权。无价值分数用户以不调节作为兜底。
拉新广告：未安装可出。

数据准备：准备 JSONL 数据文件

数据定义规划

数据空间（DS）：did
字节1：已安装态（0=未安装/未知，1=已安装）
字节2：用户级别（1=低价值、2=中等价值、3=高价值、0=未知）

由客户规划各编号字段所指代的意义，生产 users.jsonl 文件，每行包含一个用户的数据：

例如下面将 U8区第1字节作为已安装态，第2字节作为用户级别

{"userid":"张三","bytesKv":{"1":1,"2":1}}
{"userid":"李四","bytesKv":{"1":1,"2":2}}
{"userid":"王五","bytesKv":{"1":1,"2":3}}

数据格式说明

userid：设备号（MD5值小写）
bytesKv：字节数据映射表（key为字节索引1-64，value为字节值0-255）
- {"1":1,"2":1}：字节索引1=1（已安装），字节索引2=1（低价值）
- {"1":1,"2":2}：字节索引1=1（已安装），字节索引2=2（中等价值）
- {"1":1,"2":3}：字节索引1=1（已安装），字节索引2=3（高价值）

数据准备：通过 saastool 写入服务端

使用命令行工具将数据写入 sRTA 平台：

write 功能用于少量数据写入，如需大量数据写入，请使用 saastool task 能力。

saastool write -ds did -source ./users.jsonl

输出示例

写入成功时，命令会显示处理进度和统计信息：

[./users.jsonl]  err_batch = 0, err_total = 0, total_processed = 3

err_batch: 当前批次写入失败的记录数
err_total: 累计写入失败的记录数
total_processed: 已处理的记录总数

如果有用户写入失败，失败的用户ID会被记录到 WriteRes.failedUserid 字段中

数据准备：DS 中的数据存储

写入成功后，数据在 Redis 中的存储格式为字节数据。sRTA lua在查询时会自动取出当前用户下的数据转换为 dataspace Table变量供 Lua 脚本使用：

"张三" = {[srta.U8] = {[1] = 1, [2] = 1}} --字节索引1=1 (已安装），字节索引2=1（低价值）
"李四" = {[srta.U8] = {[1] = 1, [2] = 2}} --字节索引1=1（已安装），字节索引2=2（中价值）
"王五" = {[srta.U8] = {[1] = 1, [2] = 3}} --字节索引1=1（已安装），字节索引2=3（高价值）

脚本：编写 Lua 实现拉活与调权

创建 sample.lua 脚本，实现根据用户安装态及级别判断的拉活和调节系数：

-- sample.lua:
-- 已安装：根据用户级别调节系数
-- 未安装：出拉新广告

IDXU8_USER_INSTALLED = 1      -- 字节索引1：已安装态
IDXU8_USER_LEVEL = 2          -- 字节索引2：用户级别

-- 主函数：在每次用户决策时被调用
function main()
    -- 从DID数据空间获取用户信息，此处无须填写用户ID，该映射关系由sRTA平台自动处理为当前用户
    didData = srta.get_dsdata(srta.DS_DID)
    installed = didData[srta.U8][IDXU8_USER_INSTALLED] == 1 -- 是否已安装
    userLevel = didData[srta.U8][IDXU8_USER_LEVEL] == 1 -- 用户级别
    
    local results = {} -- 定义返回结果

    local targets = srta.get_targets() -- 获取所有策略ID

    for _, targetid in ipairs(targets) do
        print("installed", installed) -- 打印已安装状态。在手工调试时会输出，在正式运行时自动被禁止。

        if targetid == "active" and installed then -- 拉活策略
            if userLevel == 3 then
                results[targetid] = {
                    [srta.TARGETINFO_ENABLE] = true,
                    [srta.TARGETINFO_USER_WEIGHT_FACTOR]= 1.3 -- 高价值用户提权
                }
            elseif userLevel == 2 then
                results[targetid] = {
                    [srta.TARGETINFO_ENABLE] = true,
                    [srta.TARGETINFO_USER_WEIGHT_FACTOR]= 1.0 -- 中价值用户维持
                }
            elseif userLevel == 1 then
                results[targetid] = {
                    [srta.TARGETINFO_ENABLE] = true,
                    [srta.TARGETINFO_USER_WEIGHT_FACTOR]= 0.8 --低价值用户降权
                }
            else 
                results[targetid] = {
                    [srta.TARGETINFO_ENABLE] = true -- 其他情况不调节
                }
            end
        else if targetid=="new" and not installed then -- 拉新策略
            results[targetid] = {
                [srta.TARGETINFO_ENABLE] = true
            }
        end
    end

    return results
end

脚本：测试

本地测试脚本逻辑：

# 测试 USERID1（低价值用户）
saastool script debug -lua ./sample.lua -did 张三 -os 2

# 测试 USERID2（中等价值用户）
saastool script debug -lua ./sample.lua -did 李四 -os 2

# 测试 USERID3（高价值用户）
saastool script debug -lua ./sample.lua -did 王五 -os 2

脚本：上线

确认脚本测试无误后，上线脚本：

重要

脚本创建后，需要 sRTA 平台管理员审批通过才可被使用 (use)

# 创建脚本
saastool script create -lua ./sample.lua -name sample

# 设置为默认脚本
saastool script use -name sample

回收：效果验证

脚本上线后，可以通过以下方式验证效果：

# 查询实验数据
saastool exp get -beginday 20250101 -endday 20250131 -target active

2.2 数据底层

sRTA决策依赖数据源包括：来自于广告主的一方数据、来自于平台的二方数据、来自于服务商的三方数据。通过调用 API 或者使用 saastool 工具，可以将数据写入到 sRTA 数据存贮中。基本概念请参考写入流程简述。

2.2.1 一方数据

以下是一方数据存储中的结构示意.

2.2.1.1 数据空间

每个账号下可以有多个数据空间，数据空间有多种类型：

DID存储区：以设备号为key的存储区。设备号为OAID MD5 / CAID 20230330版 MD5。用于基于设备号的数据存储。
WUID存储区：以WUID为key的存储区。用于基于 手机号 / OpenID / UnionID 的数据存储，原始ID会在后台会转换为WUID。
GEO存储区：以门店ID为key的存储区。用于基于经纬度的门店数据存储。
GEOIP存储区：以行政区划码为key的存储区。用于基于IP映射城市编码的数据存储。
GEOFAC存储区：以行政区划码为key的存储区。用于基于常住地城市编码的数据存储。

当数据空间容量不足时，可申请更多独立空间。

2.2.1.2 数据空间内存储

每种存储区有三种类型的字段，可满足不同场景的诉求。

sRTA 存储结构

uint8：共 64 个。
uint32：共 8 个。
flagWithExpire：共 4 个。

2.2.1.3 字段使用

每个数组的一个值可视为 一列 或 一个维度，除有特别约定的GEO区外，其他情况下每一列存贮什么内容由使用方自由发挥。

2.2.1.4 使用示例

例如我们可将uint8 的第 0列用于App 的已安装状态，当该值为 1 时，即表示已安装。

sRTA 存储结构

2.2.1.5 底层存储结构示意

// 仅作伪代码示意，非真实存储结构
#include <stdint.h>
#include <stdbool.h>

struct FlagWithExpire {
    bool flag;                                 // 标志位
    bool default_flag;                         // 默认值
    uint32_t expire;                           // 过期时间戳
};

struct StoreValue{
    uint8_t bytes[64];                         // byte型存储
    uint32_t uint32s[8];                       // uint32型存储
    struct FlagWithExpire flag_with_expire[4]; // flag型存储
};

2.2.1.6 默认值

uint8默认值：0
uint32默认值：0
flagWighExpire默认值：flag = false, default_flag = false，expire = 0

2.2.2 二方数据

二方数据通过 srta 库函数获取。

2.2.2.1 获取安装态

一次可以获得多个App安装态，每个返回值为 true(已安装)/false(未安装)/nil(无权限或不可靠)中的一个状态，参考函数srta.get_apps。

2.2.3 三方数据

三方数据通过 srta 库函数获取，每个维度的数据均需要独立授权。某些三方数据需要收费，请与数据提供方洽淡。

2.2.3.1 获取打分

一次可以获得多个模型打分，每个返回值为数字/nil(无权限或不可靠)中的一个状态，参考函数srta.get_scores。

编号	模型	收费模式
1	个贷意愿分	金融行业免费
2	金融质量分	金融行业免费
3	金融通过分	金融行业免费
4	金融提现分	金融行业免费
5	新版逾期分	金融行业免费
6	提现意愿分V2	金融行业免费
10	企业主资质分	金融行业免费
11	企业贷意愿分	金融行业免费
20	保险续保分	金融行业免费

2.3 数据写入

2.3.1 DID数据写入(DID区)

DID（Device ID）数据区用于存储设备维度的用户数据，支持通过设备ID（OAID MD5 / CAID 20230330版 MD5）进行数据读写。本节介绍DID数据写入的完整流程。

2.3.1.1 检查数据区开通状态

在写入数据前，先使用 saastool info 命令检查是否已开通 DID 数据区。

saastool info

如显示的 dataspace 节点下有 did 字段，则表明已开通 DID 数据区；若不存在，需联系管理员开通。

Info res: {
  "dataspace": {
    "did": [
      "did",
      "20010101"
    ]
  },
  "targetId": []
}

"did": 数据空间别名，可在命令中使用此别名
"20010101": 数据空间数字ID，也可在命令中使用
targetId: 已创建的策略ID列表（为空表示未创建策略）

2.3.1.2 数据准备

数据格式说明

DID 数据需要准备为 JSONL 格式（每行一个 JSON 对象），每个 JSON 对象包含以下字段：

字段名	类型	必填	说明
`userid`	string	是	用户设备ID的 MD5 值（32位小写）
`bytesKv`	object	否	UINT8 字段区，key 为索引（1-64），value 为数值（0-255）
`uint32sKv`	object	否	UINT32 字段区，key 为索引（1-8），value 为数值（0-4294967295）
`flagsWithExpireKv`	object	否	FLAG 标志位字段区，key 为索引（1-4），value 为标志对象

FLAG 字段格式说明：

{"flag": true} - 置位为 true，永不过期
{"flag": false} - 置位为 false
{"flag": true, "expire": 1758686629} - 在指定 Unix 时间戳前为 true，之后为 false

数据准备示例

创建数据文件 users.jsonl：

{"userid":"cfcd208495d565ef66e7dff9f98764da","bytesKv":{"1":1,"2":100},"uint32sKv":{"1":1000000}}
{"userid":"a87ff679a2f3e71d9181a67b7542122c","bytesKv":{"1":2,"2":200},"flagsWithExpireKv":{"1":{"flag":true}}}
{"userid":"9dd4e461268c8034f5c8564e155c67a6","bytesKv":{"3":50},"uint32sKv":{"2":5000000},"flagsWithExpireKv":{"2":{"flag":true,"expire":1758686629}}}

字段含义示例：

第1条：用户 cfcd2084... 的 U8[1]=1, U8[2]=100, U32[1]=1000000
第2条：用户 a87ff679... 的 U8[1]=2, U8[2]=200, FLAG[1]=true（永久）
第3条：用户 9dd4e461... 的 U8[3]=50, U32[2]=5000000, FLAG[2]=true（在2025年9月24日12:03:49前有效）

2.3.1.3 写入方法

方法一：使用 saastool 命令行工具写入

1. 批量写入文件

# 写入单个 JSONL 文件
saastool write -ds did -source ./users.jsonl

# 写入目录下所有 JSONL 文件
saastool write -ds did -source ./data_dir/

# 指定批处理大小（默认 10000）
saastool write -ds did -source ./users.jsonl -batchsize 5000

2. 写入前清空用户数据

使用 -clear 参数可在写入前清空该用户的所有字段数据：

saastool write -ds did -source ./users.jsonl -clear

注意

-clear 参数会清空用户的所有字段，请谨慎使用。建议仅在需要完全覆盖用户数据时使用。

3. 查看写入结果

# 读取写入的数据进行验证
saastool read -ds did -userids cfcd208495d565ef66e7dff9f98764da

返回示例：

{
  "succCmdCount": 1,
  "failCmdCount": 0,
  "cmdRes": [
    {
      "cmdIndex": 0,
      "cmdCode": "OK",
      "bytesKv": {
        "1": 1,
        "2": 100
      },
      "uint32sKv": {
        "1": 1000000
      },
      "lastModifyTime": 1709712345,
      "version": 1
    }
  ]
}

字段说明：

succCmdCount: 成功读取的用户数
failCmdCount: 失败的用户数
cmdRes[]: 每个用户的数据
- bytesKv: UINT8 字段数据
- uint32sKv: UINT32 字段数据
- flagsWithExpireKv: FLAG 字段数据
- lastModifyTime: 最后修改时间（Unix 时间戳）
- version: 数据版本号

方法二：使用 API 接口写入

通过调用 HTTP API 接口进行数据写入，适用于需要程序化集成的场景。

1. API 请求格式

请求方式：POST
请求地址：
- 正式环境：https://api.rta.qq.com/saas/write
- 演示环境：https://srta.algo.com.cn/saas/write
请求头：
- Content-Type: application/x-protobuf
- X-Account-ID: {账号ID}
- Authorization: {Token}
请求体：protobuf 格式的 SaasReq 消息

2. protobuf 请求结构

message SaasReq {
    Write write = 11;
}

message Write {
    string dataspace_id = 1;           // 数据空间ID，填 "did"
    bool is_clear_all_first = 3;       // 是否先清空该用户所有数据
    repeated WriteItem write_items = 4; // 批量写入命令
}

message WriteItem {
    string userid = 1;                 // 用户ID（设备ID的MD5）
    map<uint32, uint32> bytes_kv = 5;  // UINT8 字段区
    map<uint32, uint32> uint32s_kv = 6; // UINT32 字段区
    map<uint32, FlagWithExpire> flags_with_expire_kv = 7; // FLAG 字段区
}

3. Go 示例代码

使用 saastool 中已实现的 saashttp.SaasClient 客户端进行写入（推荐方式）：

package main

import (
    "fmt"
    "net/http"
    
    "git.algo.com.cn/public/saasapi"
    "git.algo.com.cn/public/saasapi/pkg/saashttp"
)

func main() {
    // 初始化 API URLs（演示环境）
    apiUrls := saashttp.InitAPIUrl(&saashttp.ApiUrlsCfg{
        BaseUrl: "https://srta.algo.com.cn", // 演示环境
        // 正式环境请使用: "https://api.rta.qq.com"
    })
    
    // 创建 SaasClient
    client := &saashttp.SaasClient{
        Client:  &http.Client{},
        ApiUrls: apiUrls,
        Auth: &saashttp.Auth{
            Account: "2000",           // 账号 ID
            Token:   "your_token_here", // Token
        },
    }
    
    // 构造写入请求
    req := &saasapi.SaasReq{
        Cmd: &saasapi.SaasReq_Write{
            Write: &saasapi.Write{
                DataspaceId:     "did",
                IsClearAllFirst: false,
                WriteItems: []*saasapi.WriteItem{
                    {
                        Userid: "cfcd208495d565ef66e7dff9f98764da",
                        BytesKv: map[uint32]uint32{
                            1: 1,
                            2: 100,
                        },
                        Uint32SKv: map[uint32]uint32{
                            1: 1000000,
                        },
                    },
                    {
                        Userid: "a87ff679a2f3e71d9181a67b7542122c",
                        BytesKv: map[uint32]uint32{
                            1: 2,
                            2: 200,
                        },
                        FlagsWithExpireKv: map[uint32]*saasapi.FlagWithExpire{
                            1: {Flag: true},
                        },
                    },
                },
            },
        },
    }
    
    // 调用 Write 方法
    res, err := client.Write(req)
    if err != nil {
        fmt.Printf("写入失败: %v\n", err)
        return
    }
    
    // 处理响应
    if res.Code == saasapi.ErrorCode_SUCC {
        fmt.Println("写入成功")
        if len(res.GetWriteRes().GetFailedUserid()) > 0 {
            fmt.Printf("部分用户写入失败: %v\n", res.GetWriteRes().GetFailedUserid())
        }
    } else {
        fmt.Printf("写入失败: code=%v, status=%s\n", res.Code, res.Status)
    }
}

代码说明：

使用 saashttp 包：git.algo.com.cn/public/saasapi/pkg/saashttp 提供了完整的客户端实现
SaasClient 封装：
- ApiUrls：API 地址配置（自动处理 /saas/write 等路径）
- Auth：认证信息（自动处理鉴权签名）
- Client：HTTP 客户端
Write 方法：自动完成序列化、请求发送、响应解析等操作
错误处理：返回 (res, err) 两个值，需分别检查网络错误和业务错误

优势：

✅ 无需手动处理 HTTP 请求/响应
✅ 无需手动计算鉴权签名（自动处理 MD5 签名）
✅ 自动处理 protobuf 序列化/反序列化
✅ 复用 saastool 已验证的代码
✅ 支持所有 API 接口（Read、TaskCreate、TaskUpload 等）

方法三：使用 saastool HTTP daemon 模式

saastool 支持以 HTTP 服务模式运行，提供简单的 HTTP 接口进行数据读写。

1. 启动 daemon 服务

# 设置环境变量
export SRTA_ACCOUNT=2000
export SRTA_TOKEN=your_token_here
export SRTA_ENV=demo  # 或 prd
export SRTA_PORT=8080

# 启动 daemon
saastool daemon

2. 单个用户写入（GET 请求）

# 写入单个用户数据
curl "http://localhost:8080/write?ds=did&userid=cfcd208495d565ef66e7dff9f98764da&u8.1=10&u8.2=100&u32.1=1000000"

# 写入前先清空
curl "http://localhost:8080/write?ds=did&userid=cfcd208495d565ef66e7dff9f98764da&u8.1=10&u32.1=1000000&clear=true"

# 写入 FLAG 字段
curl "http://localhost:8080/write?ds=did&userid=cfcd208495d565ef66e7dff9f98764da&flag.1=true&flag.2=1758686629&flag.3=!3600"

FLAG 字段格式说明：

flag.1=true 或 flag.1=false - 永久有效的标志位
flag.2=1758686629 - 在指定 Unix 时间戳前为 true
flag.3=!3600 - 在当前时间 + 3600 秒前为 true

3. 批量写入（POST 请求）

curl -X POST "http://localhost:8080/write?ds=did" \
  -H "Content-Type: text/plain" \
  -d "userid=cfcd208495d565ef66e7dff9f98764da&u8.1=10&u32.1=1000000" \
  -d "userid=a87ff679a2f3e71d9181a67b7542122c&u8.1=60&flag.2=true" \
  -d "userid=9dd4e461268c8034f5c8564e155c67a6&u8.2=200&u32.6=1000000&flag.3=!3600"

方法四：使用 Task 任务批量写入（推荐大数据量）

Task 任务模式用于亿级用户数据的批量写入，具有并发写入量大、支持断点续传、批量集中执行的特点。适用于千万级以上的数据写入场景。

适用场景：

数据量 ≥ 1000万条记录
需要批量更新大量用户的字段数据
需要断点续传支持（网络不稳定环境）
定期全量数据更新

优势：

支持大数据量（亿级）批量写入
支持分块上传和断点续传
可并发上传多个分块，提升效率
自动去重（相同 SHA256 的分块无需重复上传）
任务执行状态可查询

完整流程：

步骤1：准备数据文件

数据格式与方法一相同，准备 JSONL 格式的数据文件：

{"userid":"cfcd208495d565ef66e7dff9f98764da","bytesKv":{"1":1,"2":100},"uint32sKv":{"1":1000000}}
{"userid":"a87ff679a2f3e71d9181a67b7542122c","bytesKv":{"1":2,"2":200},"flagsWithExpireKv":{"1":{"flag":true}}}
{"userid":"9dd4e461268c8034f5c8564e155c67a6","bytesKv":{"3":50},"uint32sKv":{"2":5000000},"flagsWithExpireKv":{"2":{"flag":true,"expire":1758686629}}}

步骤2：生成任务元数据文件（Make）

使用 saastool task make 命令扫描数据文件，计算分块 SHA256，生成任务元数据文件：

# 为单个文件生成任务元数据
saastool task make \
  -source ./users.jsonl \
  -hash ./task.json \
  -ds did \
  -blocksize 200M \
  -desc "DID用户数据批量写入任务"

# 为目录下所有文件生成任务元数据
saastool task make \
  -source ./data_dir/ \
  -hash ./task.json \
  -ds did \
  -blocksize 200M \
  -desc "DID批量数据导入"

参数说明：

-source：数据源路径（文件或目录）
-hash：输出的任务元数据文件路径（JSON 格式）
-ds：数据空间 ID（did 或 wuid）
-blocksize：分块大小（10M-200M，推荐 200M）
-desc：任务描述（可选）
-appid：微信 AppID（仅 wuid 数据区需要，可选）
-accountid：账号 ID（wuid + appid 时必填）
-hashtype：哈希类型（wuid 专用，1=PHONE_MD5, 2=PHONE_SHA256）

步骤3：创建任务（Create）

将任务元数据文件提交到服务器，创建任务：

saastool task create -hash ./task.json

返回示例：

{
  "dataspaceId": "did",
  "taskSha256": "a1b2c3d4e5f67890abcdef1234567890abcdef1234567890abcdef1234567890",
  "taskDescription": "DID用户数据批量写入任务",
  "taskFileInfos": [
    {
      "fileName": "users.jsonl",
      "fileSize": "52428800",
      "fileBlocks": [
        {
          "blockSha256": "abc123def456...",
          "blockLength": "52428800",
          "uploaded": false
        }
      ]
    }
  ],
  "taskBlockSize": "52428800",
  "sourcePath": "./users.jsonl",
  "taskSize": "52428800",
  "createTime": "2025-03-06T10:00:00Z",
  "status": "WAITING",
  "totalBlock": 1
}

字段说明：

taskSha256：任务的唯一标识（SHA256 哈希值）
dataspaceId：数据空间 ID
status：任务状态（WAITING = 等待上传）
totalBlock：总分块数
taskFileInfos[].fileBlocks[].uploaded：该分块是否已上传（false 表示需要上传）
createTime：任务创建时间

步骤4：上传数据分块（Upload）

将数据文件的各个分块上传到服务器（支持并发上传）：

saastool task upload -sha256 a1b2c3d4e5f6...

提示

上传前会自动检查分块是否已存在，已上传的分块会跳过（断点续传）
数据会自动使用 gzip 压缩，减少网络传输
支持并发上传多个分块，加快上传速度

步骤5：执行任务（Run）

所有分块上传完成后，执行任务将数据写入数据区：

saastool task run -sha256 a1b2c3d4e5f67890abcdef1234567890abcdef1234567890abcdef1234567890

返回示例：

task run success {"code":"SUCC","taskRunRes":{"dataspaceId":"did","taskSha256":"a1b2c3d4e5f67890abcdef1234567890abcdef1234567890abcdef1234567890","status":"RUNNING","createTime":"2025-03-06T10:00:00Z","runTime":"2025-03-06T11:00:00Z"}}

任务提交成功后，状态变为 RUNNING（运行中）。

注意

同一时间只能执行一个任务
如果有任务正在运行，新任务会自动进入队列等待
任务执行期间无法调用实时写入接口

步骤6：查询任务状态

查看任务执行状态和进度：

# 查看所有任务列表
saastool task list

# 查看特定任务详情
saastool task info -sha256 a1b2c3d4e5f67890abcdef1234567890abcdef1234567890abcdef1234567890

# 筛选特定状态的任务
saastool task list -status running   # 运行中
saastool task list -status success   # 成功
saastool task list -status fail      # 失败

task list 返回示例：

task res: {
  "tasks": [
    {
      "dataspaceId": "did",
      "taskSha256": "a1b2c3d4e5f67890abcdef1234567890abcdef1234567890abcdef1234567890",
      "taskDescription": "DID用户数据批量写入任务",
      "taskBlockSize": "209715200",
      "taskSize": "524288000",
      "createTime": "2025-03-06T10:00:00Z",
      "status": "WAITING",
      "totalBlock": 3
    },
    {
      "dataspaceId": "did",
      "taskSha256": "b2c3d4e5f67890abcdef1234567890abcdef1234567890abcdef1234567890ab",
      "taskDescription": "历史数据导入",
      "taskBlockSize": "209715200",
      "taskSize": "104857600",
      "createTime": "2025-03-05T15:30:00Z",
      "runTime": "2025-03-05T16:00:00Z",
      "finishTime": "2025-03-05T17:00:00Z",
      "status": "SUCCESS",
      "totalBlock": 1
    }
  ]
}

task info 返回示例：

task res: {
  "dataspaceId": "did",
  "taskSha256": "a1b2c3d4e5f67890abcdef1234567890abcdef1234567890abcdef1234567890",
  "taskDescription": "DID用户数据批量写入任务",
  "taskFileInfos": [
    {
      "fileName": "users.jsonl",
      "fileSize": "52428800",
      "fileBlocks": [
        {
          "blockSha256": "abc123def456...",
          "blockLength": "52428800",
          "uploaded": true
        }
      ]
    }
  ],
  "taskBlockSize": "52428800",
  "sourcePath": "./users.jsonl",
  "taskSize": "52428800",
  "createTime": "2025-03-06T10:00:00Z",
  "status": "READY",
  "totalBlock": 1
}

任务状态说明：

WAITING (1)：等待上传，已创建但分块未全部上传
READY (2)：上传完毕，等待执行
RUNNING (3)：运行中，正在写入数据
SUCCESS (4)：执行成功
FAIL (5)：执行失败

步骤7：删除任务（可选）

删除不需要的任务（成功或失败的任务）：

saastool task delete -sha256 a1b2c3d4e5f67890abcdef1234567890abcdef1234567890abcdef1234567890

返回示例：

task res: {
  "dataspaceId": "did",
  "taskSha256": "a1b2c3d4e5f67890abcdef1234567890abcdef1234567890abcdef1234567890",
  "status": "DELETED"
}

信息

新创建的任务会在 7 天内自动删除（如未执行）
成功或失败的任务建议手动删除，释放存储空间
正在运行的任务会先中断再删除

完整示例脚本：

#!/bin/bash

# 1. 准备数据（假设已有 data/ 目录下的 JSONL 文件）

# 2. 生成任务元数据
echo "Step 1: 生成任务元数据..."
saastool task make \
  -source ./data/ \
  -hash ./task.json \
  -ds did \
  -blocksize 200M \
  -desc "$(date +%Y%m%d) DID数据批量导入"

# 3. 创建任务
echo "Step 2: 创建任务..."
TASK_SHA256=$(saastool task create -hash ./task.json | grep -oP 'taskSha256":\s*"\K[^"]+')
echo "任务SHA256: $TASK_SHA256"

# 4. 上传分块
echo "Step 3: 上传数据分块..."
saastool task upload -sha256 $TASK_SHA256

# 5. 执行任务
echo "Step 4: 执行任务..."
saastool task run -sha256 $TASK_SHA256

# 6. 循环查询任务状态，直到完成
echo "Step 5: 监控任务执行..."
while true; do
    STATUS=$(saastool task info -sha256 $TASK_SHA256 | grep -oP 'status":\s*"\K[^"]+')
    echo "当前状态: $STATUS"
    
    if [ "$STATUS" == "SUCCESS" ]; then
        echo "✅ 任务执行成功！"
        break
    elif [ "$STATUS" == "FAIL" ]; then
        echo "❌ 任务执行失败！"
        saastool task info -sha256 $TASK_SHA256
        exit 1
    fi
    
    sleep 10
done

# 7. 可选：删除任务
echo "Step 6: 删除任务..."
saastool task delete -sha256 $TASK_SHA256

echo "✅ 所有步骤完成！"

API 方式调用：

Task 模式也支持通过 API 调用，主要接口如下：

接口	路径	说明
创建任务	`/saas/task/create`	提交任务元数据
上传分块	`/saas/task/upload`	上传数据分块（需 gzip 压缩）
执行任务	`/saas/task/run`	开始执行写入
查询列表	`/saas/task/list`	列出所有任务
查询详情	`/saas/task/info`	获取任务详细信息
删除任务	`/saas/task/delete`	删除指定任务

详细的 API 调用格式请参考 API 文档 - 任务管理。

Task 模式注意事项：

分块大小选择：
- 推荐使用 200M 分块大小（默认值）
- 分块大小范围：10M-200M
- 文件最后一个分块可能小于设定的分块大小
并发上传优化：
- 可以并发上传多个分块，显著提升上传效率
- 建议并发数：4-8 个线程
- 上传前先调用 /saas/task/info 检查 uploaded 状态，跳过已上传的分块
任务执行限制：
- 同一时间只能运行一个任务
- 任务运行期间，实时写入接口（/saas/write）会被阻塞
- 任务执行时间取决于数据量（亿级数据约需数小时）
数据格式要求：
- 数据文件必须是 JSONL 格式（每行一个 JSON 对象）
- JSON 格式与实时写入的 WriteItem 结构完全一致
- 支持 bytesKv、uint32sKv、flagsWithExpireKv 三种字段类型
任务清理：
- 未上传完成的任务会在 7 天后自动删除
- 成功或失败的任务建议手动删除
- 可通过 /saas/task/list 定期清理过期任务

2.3.1.5 数据验证

写入完成后，建议进行数据验证：

# 读取验证
saastool read -ds did -userids cfcd208495d565ef66e7dff9f98764da

# 或使用 HTTP daemon
curl "http://localhost:8080/read?ds=did&userid=cfcd208495d565ef66e7dff9f98764da"

2.3.1.6 写入方法对比

对比项	方法一：CLI 工具	方法二：API 接口	方法三：HTTP Daemon	方法四：Task 任务
适用场景	小批量数据、脚本自动化	程序集成、实时写入	轻量级 HTTP 服务	大批量数据（千万级+）
数据量级	< 100万	< 1000万	< 100万	≥ 1000万（亿级）
写入速度	中等	快速	快速	最快（批量并发）
断点续传	不支持	不支持	不支持	支持
并发能力	顺序执行	支持并发请求	支持并发请求	支持分块并发上传
网络要求	一般	较高	一般	较低（支持重传）
技术门槛	低（命令行）	高（需编程）	中（HTTP 调用）	中（命令行+流程）
实时性	实时	实时	实时	异步（需执行任务）
推荐使用	开发测试、小批量	生产环境实时更新	快速原型、测试	大批量全量导入

选择建议：

日常测试、小批量数据 → 方法一（CLI）
程序集成、实时数据更新 → 方法二（API）
快速验证、轻量级服务 → 方法三（Daemon）
千万级以上大批量数据 → 方法四（Task）

2.3.1.7 注意事项

用户ID格式：DID 数据区的 userid 必须是设备ID的 MD5 值（32位小写十六进制字符串）
字段索引范围：
- UINT8 字段：索引 1-64，值范围 0-255
- UINT32 字段：索引 1-8，值范围 0-4294967295
- FLAG 字段：索引 1-4，值为布尔型
批处理大小：实时写入建议单次不超过 10000 条记录，大批量数据建议使用 Task 模式
过期时间：FLAG 字段支持设置过期时间，过期后自动变为 false
增量写入：默认为增量写入（覆盖指定字段），使用 -clear 参数可先清空再写入
失败重试：API 返回失败的 userid 列表，建议对失败的数据进行重试
写入互斥：Task 任务运行期间，实时写入接口会被阻塞，需等任务完成

2.3.1.8 最佳实践

数据分批：
- 实时写入：每批不超过 10000 条记录
- Task 写入：大批量数据建议使用 Task 模式，单个分块 200M
错误处理：API 调用时务必检查返回的 failed_userid，对失败的记录进行重试或记录日志
过期策略：合理使用 FLAG 字段的过期时间，避免过期数据占用存储空间
字段规划：提前规划好字段索引的用途，避免后期混乱（建议维护字段索引文档）
测试验证：生产环境写入前，建议先在演示环境（demo）进行测试验证
任务管理：
- 定期清理已完成的 Task 任务，释放存储空间
- 大批量数据更新建议在业务低峰期执行
- 使用监控脚本跟踪任务执行状态

2.3.2 手机号数据写入(WUID区)

WUID（WeChat User ID）数据区用于存储基于手机号的用户数据。与 DID 数据区不同，WUID 数据区需要提供手机号的哈希值（MD5 或 SHA256）作为用户标识。本节介绍手机号数据写入的完整流程。

2.3.2.1 检查数据区开通状态

在写入数据前，先使用 saastool info 命令检查是否已开通 WUID 数据区。

saastool info

如显示的 dataspace 节点下有 wuid 字段，则表明已开通 WUID 数据区；若不存在，需联系管理员开通。

Info res: {
  "dataspace": {
    "wuid": [
      "wuid",
      "20010201"
    ]
  },
  "targetId": []
}

"wuid": 数据空间别名
"20010201": 数据空间数字ID

重要警告：字段索引规划

手机号数据和 OpenID 数据共用同一个 WUID 数据区，因此必须提前规划好字段索引编号，避免不同数据类型使用相同的索引导致数据覆盖冲突！

字段索引范围：

UINT8 字段：索引 1-64
UINT32 字段：索引 1-8
FLAG 字段：索引 1-4

规划建议示例：

手机号数据：U8[1-32], U32[1-4], FLAG[1-2]
OpenID 数据：U8[33-64], U32[5-8], FLAG[3-4]

后果说明：

如果手机号数据和 OpenID 数据都使用 U8[1]，后写入的数据会覆盖先写入的数据
字段覆盖不会有错误提示，但会导致数据丢失或混乱
务必在项目初期做好字段索引分配规划，并在团队内文档化

2.3.2.2 数据准备

数据格式说明

WUID 数据需要准备为 JSONL 格式，每个 JSON 对象包含以下字段：

字段名	类型	必填	说明
`userid`	string	是	手机号的哈希值（MD5 或 SHA256）
`bytesKv`	object	否	UINT8 字段区，key 为索引（1-64），value 为数值（0-255）
`uint32sKv`	object	否	UINT32 字段区，key 为索引（1-8），value 为数值（0-4294967295）
`flagsWithExpireKv`	object	否	FLAG 标志位字段区，key 为索引（1-4），value 为标志对象

手机号哈希计算方式：

MD5：对手机号（不含空格、横杠等分隔符）计算 MD5 值，取小写32位十六进制字符串
- 示例：13800138000 → e10adc3949ba59abbe56e057f20f883e（示例值）
SHA256：对手机号计算 SHA256 值，取小写64位十六进制字符串
- 示例：13800138000 → 5e884898da28047151d0e56f8dc6292773603d0d6aabbdd62a11ef721d1542d8（示例值）

数据准备示例

创建数据文件 users_phone.jsonl：

{"userid":"e10adc3949ba59abbe56e057f20f883e","bytesKv":{"1":1,"2":100},"uint32sKv":{"1":1000000}}
{"userid":"c33367701511b4f6020ec61ded352059","bytesKv":{"1":2,"2":200},"flagsWithExpireKv":{"1":{"flag":true}}}
{"userid":"5e884898da28047151d0e56f8dc6292773603d0d6aabbdd62a11ef721d1542d8","bytesKv":{"3":50},"uint32sKv":{"2":5000000},"flagsWithExpireKv":{"2":{"flag":true,"expire":1758686629}}}

字段含义示例：

第1条：手机号MD5为 e10adc3... 的用户，U8[1]=1, U8[2]=100, U32[1]=1000000
第2条：手机号MD5为 c333677... 的用户，U8[1]=2, U8[2]=200, FLAG[1]=true（永久）
第3条：手机号SHA256为 5e88489... 的用户，U8[3]=50, U32[2]=5000000, FLAG[2]=true（在2025年9月24日前有效）

2.3.2.3 写入方法

方法一：使用 saastool 命令行工具写入（手机号哈希）

1. 批量写入文件

# 写入手机号MD5数据
saastool write -ds wuid -source ./users_phone.jsonl -hashtype 1

# 写入手机号SHA256数据
saastool write -ds wuid -source ./users_phone.jsonl -hashtype 2

# 指定批处理大小
saastool write -ds wuid -source ./users_phone.jsonl -hashtype 1 -batchsize 5000

参数说明：

-ds wuid：指定数据空间为 WUID
-hashtype：必填，指定哈希类型
- 1：手机号 MD5
- 2：手机号 SHA256

2. 写入前清空用户数据

saastool write -ds wuid -source ./users_phone.jsonl -hashtype 1 -clear

3. 查看写入结果

# 读取写入的数据进行验证
saastool read -ds wuid -userids e10adc3949ba59abbe56e057f20f883e -hashtype 1

方法二：使用 API 接口写入（手机号哈希）

Go 示例代码：

package main

import (
    "fmt"
    "net/http"
    
    "git.algo.com.cn/public/saasapi"
    "git.algo.com.cn/public/saasapi/pkg/saashttp"
)

func main() {
    apiUrls := saashttp.InitAPIUrl(&saashttp.ApiUrlsCfg{
        BaseUrl: "https://srta.algo.com.cn",
    })
    
    client := &saashttp.SaasClient{
        Client:  &http.Client{},
        ApiUrls: apiUrls,
        Auth: &saashttp.Auth{
            Account: "2000",
            Token:   "your_token_here",
        },
    }
    
    // 构造写入请求（手机号MD5）
    req := &saasapi.SaasReq{
        Cmd: &saasapi.SaasReq_Write{
            Write: &saasapi.Write{
                DataspaceId:     "wuid",
                HashType:        saasapi.HashType_PHONE_MD5, // 手机号MD5
                IsClearAllFirst: false,
                WriteItems: []*saasapi.WriteItem{
                    {
                        Userid: "e10adc3949ba59abbe56e057f20f883e", // 手机号MD5值
                        BytesKv: map[uint32]uint32{
                            1: 1,
                            2: 100,
                        },
                        Uint32SKv: map[uint32]uint32{
                            1: 1000000,
                        },
                    },
                },
            },
        },
    }
    
    res, err := client.Write(req)
    if err != nil {
        fmt.Printf("写入失败: %v\n", err)
        return
    }
    
    if res.Code == saasapi.ErrorCode_SUCC {
        fmt.Println("写入成功")
    } else {
        fmt.Printf("写入失败: code=%v, status=%s\n", res.Code, res.Status)
    }
}

重要说明：

使用 WUID 数据区时，必须指定 hash_type 参数
hash_type 可选值：
- saasapi.HashType_PHONE_MD5 (1)：手机号 MD5
- saasapi.HashType_PHONE_SHA256 (2)：手机号 SHA256

方法三：使用 Task 任务批量写入（推荐大数据量）

适用于千万级以上手机号数据的批量写入场景。

完整流程：

步骤1：准备数据文件

{"userid":"e10adc3949ba59abbe56e057f20f883e","bytesKv":{"1":1,"2":100},"uint32sKv":{"1":1000000}}
{"userid":"c33367701511b4f6020ec61ded352059","bytesKv":{"1":2,"2":200},"flagsWithExpireKv":{"1":{"flag":true}}}

步骤2：生成任务元数据文件（Make）

# 为手机号MD5数据生成任务元数据
saastool task make \
  -source ./users_phone.jsonl \
  -hash ./task_phone.json \
  -ds wuid \
  -hashtype 1 \
  -blocksize 200M \
  -desc "手机号数据批量写入任务"

# 为手机号SHA256数据生成任务元数据
saastool task make \
  -source ./users_phone.jsonl \
  -hash ./task_phone.json \
  -ds wuid \
  -hashtype 2 \
  -blocksize 200M \
  -desc "手机号SHA256数据批量写入"

参数说明：

-ds wuid：指定数据空间为 WUID
-hashtype：必填，指定哈希类型（1=PHONE_MD5, 2=PHONE_SHA256）

步骤3-7：后续步骤与 DID 数据区相同

# 3. 创建任务
saastool task create -hash ./task_phone.json

# 4. 上传数据分块
saastool task upload -sha256 <task_sha256>

# 5. 执行任务
saastool task run -sha256 <task_sha256>

# 6. 查询任务状态
saastool task info -sha256 <task_sha256>

# 7. 删除任务（可选）
saastool task delete -sha256 <task_sha256>

2.3.2.4 注意事项

用户ID格式：
- 必须是手机号的哈希值（MD5 或 SHA256）
- MD5：32位小写十六进制字符串
- SHA256：64位小写十六进制字符串
- 手机号格式：去除所有分隔符和空格（如 13800138000，不是 138-0013-8000）
哈希类型必填：
- CLI 工具：必须使用 -hashtype 参数（1=MD5, 2=SHA256）
- API 调用：必须设置 hash_type 字段
- Task 模式：必须在 task make 时指定 -hashtype
⚠️ 字段索引冲突风险：
- 手机号数据与 OpenID 数据共用 WUID 区，字段索引必须避免冲突
- UINT8 字段：索引 1-64，值范围 0-255
- UINT32 字段：索引 1-8，值范围 0-4294967295
- FLAG 字段：索引 1-4，值为布尔型
- 示例：如果手机号使用 U8[1-32]，则 OpenID 应使用 U8[33-64]
- 后果：索引重复会导致后写入的数据覆盖先写入的数据，且无错误提示
- 建议：在项目配置文档中明确记录各数据类型的字段索引分配方案
- FLAG 字段：索引 1-4，值为布尔型
哈希一致性：
- 写入和读取时必须使用相同的哈希类型
- 建议在项目中统一使用 MD5 或 SHA256
隐私保护：
- 手机号哈希后无法反推原始手机号
- 建议在客户端完成哈希计算，避免明文传输

2.3.2.5 写入方法对比

对比项	CLI 工具	API 接口	Task 任务
适用场景	小批量数据、脚本自动化	程序集成、实时写入	大批量数据（千万级+）
数据量级	< 100万	< 1000万	≥ 1000万（亿级）
hashtype 指定	命令行参数	API 字段	task make 参数

2.3.2.6 最佳实践

字段索引规划（最重要）：

务必在项目初期规划好手机号和 OpenID 的字段索引分配
建议创建字段索引分配表并在团队内共享

示例分配方案：

手机号数据：
  - U8[1-32]: 用户基础属性（如：等级、状态、标签）
  - U32[1-4]: 用户行为统计（如：购买次数、积分）
  - FLAG[1-2]: 用户标志位（如：是否VIP、是否活跃）

OpenID 数据：
  - U8[33-64]: 微信场景属性（如：订阅状态、小程序权限）
  - U32[5-8]: 微信行为统计（如：分享次数、访问次数）
  - FLAG[3-4]: 微信标志位（如：是否关注公众号）

避免后期调整索引导致数据迁移成本高

哈希类型选择：
- 优先使用 MD5（计算更快，字符串更短）
- 安全要求高的场景可使用 SHA256
- 全项目统一使用一种哈希类型
手机号格式统一：
- 去除国家代码（如 +86）
- 去除所有分隔符和空格
- 统一使用11位纯数字格式
数据验证：
- 写入前验证手机号格式
- 写入后使用 read 命令验证数据正确性
- 检查 failed_userid 并重试失败的记录

2.3.3 OpenID数据写入(WUID区)

WUID 数据区除了支持手机号数据外，还支持基于微信 OpenID / UnionID的用户数据写入。本节介绍如何通过微信小程序/公众号/视频号的 OpenID 进行数据写入。

2.3.3.1 检查数据区开通状态

在写入数据前，先使用 saastool info 命令检查是否已开通 WUID 数据区。

saastool info

如显示的 dataspace 节点下有 wuid 字段，则表明已开通 WUID 数据区；若不存在，需联系管理员开通。

Info res: {
  "dataspace": {
    "wuid": [
      "wuid",
      "20010201"
    ]
  },
  "targetId": []
}

"wuid": 数据空间别名
"20010201": 数据空间数字ID

重要警告：字段索引规划

OpenID 数据和手机号数据共用同一个 WUID 数据区，因此必须提前规划好字段索引编号，避免不同数据类型使用相同的索引导致数据覆盖冲突！

字段索引范围：

UINT8 字段：索引 1-64
UINT32 字段：索引 1-8
FLAG 字段：索引 1-4

规划建议示例：

手机号数据：U8[1-32], U32[1-4], FLAG[1-2]
OpenID 数据：U8[33-64], U32[5-8], FLAG[3-4]

后果说明：

如果手机号数据和 OpenID 数据都使用 U8[1]，后写入的数据会覆盖先写入的数据
字段覆盖不会有错误提示，但会导致数据丢失或混乱
务必在项目初期做好字段索引分配规划，并在团队内文档化

2.3.3.2 数据准备

数据格式说明

OpenID 数据需要准备为 JSONL 格式，每个 JSON 对象包含以下字段：

字段名	类型	必填	说明
`userid`	string	是	微信 OpenID 或 UnionID（原始值，无需哈希）
`bytesKv`	object	否	UINT8 字段区，key 为索引（1-64），value 为数值（0-255）
`uint32sKv`	object	否	UINT32 字段区，key 为索引（1-8），value 为数值（0-4294967295）
`flagsWithExpireKv`	object	否	FLAG 标志位字段区，key 为索引（1-4），value 为标志对象

OpenID 与 UnionID 说明：

OpenID：微信小程序/公众号/视频号的用户唯一标识，不同应用下同一用户的 OpenID 不同
UnionID：微信开放平台账号下的用户唯一标识，同一用户在不同应用下 UnionID 相同
格式：原始字符串，无需进行任何哈希处理
示例：
- OpenID：oUpF8uMuAJO_M2pxb1Q9zNjWeS6o
- UnionID：o6_bmasdasdsad6_2sgVt7hMZOPfL

数据准备示例

创建数据文件 users_openid.jsonl：

{"userid":"oUpF8uMuAJO_M2pxb1Q9zNjWeS6o","bytesKv":{"1":1,"2":100},"uint32sKv":{"1":1000000}}
{"userid":"oUpF8uMuAJO_M2pxb1Q9zNjWeS6p","bytesKv":{"1":2,"2":200},"flagsWithExpireKv":{"1":{"flag":true}}}
{"userid":"o6_bmasdasdsad6_2sgVt7hMZOPfL","bytesKv":{"3":50},"uint32sKv":{"2":5000000},"flagsWithExpireKv":{"2":{"flag":true,"expire":1758686629}}}

字段含义示例：

第1条：OpenID 为 oUpF8u... 的用户，U8[1]=1, U8[2]=100, U32[1]=1000000
第2条：OpenID 为 oUpF8u... 的用户，U8[1]=2, U8[2]=200, FLAG[1]=true（永久）
第3条：UnionID 为 o6_bma... 的用户，U8[3]=50, U32[2]=5000000, FLAG[2]=true（在2025年9月24日前有效）

2.3.3.3 写入方法

方法一：使用 saastool 命令行工具写入（OpenID）

1. 批量写入文件

# 写入 OpenID 数据（需指定 AppID 和账号ID）
saastool write \
  -ds wuid \
  -source ./users_openid.jsonl \
  -appid wx1234567890abcdef \
  -accountid 2000

# 指定批处理大小
saastool write \
  -ds wuid \
  -source ./users_openid.jsonl \
  -appid wx1234567890abcdef \
  -accountid 2000 \
  -batchsize 5000

参数说明：

-ds wuid：指定数据空间为 WUID
-appid：必填，微信小程序/公众号/视频号的 AppID
-accountid：必填，广告主账号 ID（与 AppID 配对使用）

2. 写入前清空用户数据

saastool write \
  -ds wuid \
  -source ./users_openid.jsonl \
  -appid wx1234567890abcdef \
  -accountid 2000 \
  -clear

3. 查看写入结果

# 读取写入的数据进行验证
saastool read \
  -ds wuid \
  -userids oUpF8uMuAJO_M2pxb1Q9zNjWeS6o \
  -appid wx1234567890abcdef \
  -accountid 2000

方法二：使用 API 接口写入（OpenID）

Go 示例代码：

package main

import (
    "fmt"
    "net/http"
    
    "git.algo.com.cn/public/saasapi"
    "git.algo.com.cn/public/saasapi/pkg/saashttp"
)

func main() {
    apiUrls := saashttp.InitAPIUrl(&saashttp.ApiUrlsCfg{
        BaseUrl: "https://srta.algo.com.cn",
    })
    
    client := &saashttp.SaasClient{
        Client:  &http.Client{},
        ApiUrls: apiUrls,
        Auth: &saashttp.Auth{
            Account: "2000",
            Token:   "your_token_here",
        },
    }
    
    // 构造写入请求（OpenID）
    req := &saasapi.SaasReq{
        Cmd: &saasapi.SaasReq_Write{
            Write: &saasapi.Write{
                DataspaceId:     "wuid",
                Appid:           "wx1234567890abcdef", // 微信 AppID
                AccountId:       2000,                  // 广告主账号ID
                IsClearAllFirst: false,
                WriteItems: []*saasapi.WriteItem{
                    {
                        Userid: "oUpF8uMuAJO_M2pxb1Q9zNjWeS6o", // OpenID 原始值
                        BytesKv: map[uint32]uint32{
                            1: 1,
                            2: 100,
                        },
                        Uint32SKv: map[uint32]uint32{
                            1: 1000000,
                        },
                    },
                    {
                        Userid: "oUpF8uMuAJO_M2pxb1Q9zNjWeS6p",
                        BytesKv: map[uint32]uint32{
                            1: 2,
                            2: 200,
                        },
                        FlagsWithExpireKv: map[uint32]*saasapi.FlagWithExpire{
                            1: {Flag: true},
                        },
                    },
                },
            },
        },
    }
    
    res, err := client.Write(req)
    if err != nil {
        fmt.Printf("写入失败: %v\n", err)
        return
    }
    
    if res.Code == saasapi.ErrorCode_SUCC {
        fmt.Println("写入成功")
        if len(res.GetWriteRes().GetFailedUserid()) > 0 {
            fmt.Printf("部分用户写入失败: %v\n", res.GetWriteRes().GetFailedUserid())
        }
    } else {
        fmt.Printf("写入失败: code=%v, status=%s\n", res.Code, res.Status)
    }
}

重要说明：

使用 OpenID 时，必须同时指定 appid 和 account_id 参数
appid：微信小程序/公众号/视频号的 AppID
account_id：广告主账号 ID
OpenID 使用原始值，无需哈希处理

方法三：使用 saastool HTTP daemon 模式（OpenID）

1. 启动 daemon 服务

export SRTA_ACCOUNT=2000
export SRTA_TOKEN=your_token_here
export SRTA_ENV=demo
export SRTA_PORT=8080

saastool daemon

2. 单个用户写入（GET 请求）

# 写入 OpenID 数据
curl "http://localhost:8080/write?ds=wuid&appid=wx1234567890abcdef&userid=oUpF8uMuAJO_M2pxb1Q9zNjWeS6o&u8.1=10&u32.1=1000000"

# 写入前先清空
curl "http://localhost:8080/write?ds=wuid&appid=wx1234567890abcdef&userid=oUpF8uMuAJO_M2pxb1Q9zNjWeS6o&u8.1=10&u32.1=1000000&clear=true"

3. 批量写入（POST 请求）

curl -X POST "http://localhost:8080/write?ds=wuid&appid=wx1234567890abcdef" \
  -H "Content-Type: text/plain" \
  -d "userid=oUpF8uMuAJO_M2pxb1Q9zNjWeS6o&u8.1=10&u32.1=1000000" \
  -d "userid=oUpF8uMuAJO_M2pxb1Q9zNjWeS6p&u8.1=60&flag.2=true"

方法四：使用 Task 任务批量写入（推荐大数据量）

适用于千万级以上 OpenID 数据的批量写入场景。

完整流程：

步骤1：准备数据文件

{"userid":"oUpF8uMuAJO_M2pxb1Q9zNjWeS6o","bytesKv":{"1":1,"2":100},"uint32sKv":{"1":1000000}}
{"userid":"oUpF8uMuAJO_M2pxb1Q9zNjWeS6p","bytesKv":{"1":2,"2":200},"flagsWithExpireKv":{"1":{"flag":true}}}

步骤2：生成任务元数据文件（Make）

# 为 OpenID 数据生成任务元数据
saastool task make \
  -source ./users_openid.jsonl \
  -hash ./task_openid.json \
  -ds wuid \
  -appid wx1234567890abcdef \
  -accountid 2000 \
  -blocksize 200M \
  -desc "OpenID 用户数据批量写入任务"

参数说明：

-ds wuid：指定数据空间为 WUID
-appid：必填，微信 AppID
-accountid：必填，广告主账号 ID

步骤3-7：后续步骤与 DID 数据区相同

# 3. 创建任务
saastool task create -hash ./task_openid.json

# 4. 上传数据分块
saastool task upload -sha256 <task_sha256>

# 5. 执行任务
saastool task run -sha256 <task_sha256>

# 6. 查询任务状态
saastool task info -sha256 <task_sha256>

# 7. 删除任务（可选）
saastool task delete -sha256 <task_sha256>

2.3.3.4 注意事项

AppID 与 AccountID 必填：
- 使用 OpenID 时，必须同时指定 appid 和 accountid
- appid 为微信小程序/公众号/视频号的 AppID
- accountid 为广告主账号 ID（由平台分配）
- 缺少任意一个参数都会导致写入失败
OpenID 格式：
- OpenID 使用原始字符串，无需任何哈希处理
- 区分大小写，需保持原始格式
- 典型格式：oXXXX...（28位字符）
UnionID 与 OpenID：
- UnionID 和 OpenID 可混用（底层会统一转换为 WUID）
- 建议优先使用 UnionID（跨应用唯一）
- 同一用户的 UnionID 在不同应用下相同
⚠️ 字段索引冲突风险：
- OpenID 数据与手机号数据共用 WUID 区，字段索引必须避免冲突
- UINT8 字段：索引 1-64，值范围 0-255
- UINT32 字段：索引 1-8，值范围 0-4294967295
- FLAG 字段：索引 1-4，值为布尔型
- 示例：如果手机号使用 U8[1-32]，则 OpenID 应使用 U8[33-64]
- 后果：索引重复会导致后写入的数据覆盖先写入的数据，且无错误提示
- 建议：在项目配置文档中明确记录各数据类型的字段索引分配方案
AppID 权限：
- 写入的 AppID 必须已在广告平台完成授权
- 未授权的 AppID 无法写入数据
- 如遇权限问题，请联系平台管理员

2.3.3.5 写入方法对比

对比项	CLI 工具	API 接口	HTTP Daemon	Task 任务
适用场景	小批量数据、脚本自动化	程序集成、实时写入	轻量级 HTTP 服务	大批量数据（千万级+）
数据量级	< 100万	< 1000万	< 100万	≥ 1000万（亿级）
AppID 指定	命令行参数	API 字段	URL 参数	task make 参数
AccountID 指定	命令行参数	API 字段	环境变量	task make 参数

2.3.3.6 最佳实践

字段索引规划（最重要）：
- 务必与手机号数据协调字段索引分配，避免覆盖冲突
- 参考手机号章节的索引分配方案，确保 OpenID 使用不同的索引区间
- 示例：如手机号使用 U8[1-32]，则 OpenID 使用 U8[33-64]
- 在项目配置文档中明确记录索引分配规则
- 避免后期因索引冲突导致数据混乱或丢失
AppID 管理：
- 建议为每个微信应用配置独立的 AppID
- 在配置文件或环境变量中统一管理 AppID 和 AccountID
- 避免在代码中硬编码 AppID
OpenID 格式验证：
- 写入前验证 OpenID 格式（通常以 o 开头，28位字符）
- 检查 OpenID 是否为空或包含非法字符
- 确保 OpenID 来源于微信官方 API
UnionID 优先：
- 如果应用已开通 UnionID，建议优先使用 UnionID
- UnionID 可跨应用共享数据，提升数据利用率
- UnionID 需要在微信开放平台绑定应用
数据验证：
- 写入后使用 read 命令验证数据正确性
- 检查 failed_userid 并重试失败的记录
- 定期验证 AppID 授权状态
错误处理：
- API 返回的 failed_userid 可能包含权限错误或格式错误
- 建议记录失败的 OpenID 并分析原因
- 权限错误通常需要联系平台管理员处理

2.3.3.7 OpenID 与手机号对比

对比项	OpenID 数据	手机号数据
用户标识	OpenID / UnionID（原始值）	手机号哈希（MD5/SHA256）
必填参数	`appid` + `accountid`	`hashtype`
数据格式	原始字符串，无需哈希	必须先计算哈希值
跨应用	UnionID 支持跨应用	手机号全局唯一
隐私保护	依赖微信体系	哈希后无法反推
适用场景	微信生态内的用户数据	通用用户数据，跨平台

选择建议：

微信小程序/公众号场景 → 使用 OpenID 数据
需要跨平台数据共享 → 使用 手机号数据
已有 UnionID 体系 → 优先使用 UnionID
数据隐私要求高 → 使用 手机号哈希数据

2.3.4 门店数据写入(GEO区)

GEO 数据区用于存储门店(POI)相关的用户数据。与 DID 数据区不同，GEO 数据区的 userid 为客户自定义的门店 ID，无需哈希转换。本节介绍门店数据写入的完整流程。

2.3.4.1 检查数据区开通状态

在写入数据前，先使用 saastool info 命令检查是否已开通 GEO 数据区。

saastool info

如显示的 dataspace 节点下有 geo 字段，则表明已开通 GEO 数据区；若不存在，需联系管理员开通。

Info res: {
  "dataspace": {
    "geo": [
      "geo",
      "20010701"
    ]
  },
  "targetId": []
}

"geo": 数据空间别名
"20010701": 数据空间数字ID

重要：GEO 区经纬度存储规范

GEO 区有特殊的数据存储约定：

经纬度存储规则：

UINT32 字段索引 1：存储经度（Longitude）
UINT32 字段索引 2：存储纬度（Latitude）
数值处理：经纬度需乘以 1,000,000 后存入 UINT32

示例：

原始经度：116.397128
存储值：116.397128 × 1000000 = 116397128
原始纬度：39.916527
存储值：39.916527 × 1000000 = 39916527

计算公式：

UINT32[1] = int(longitude × 1000000)  # 经度
UINT32[2] = int(latitude × 1000000)   # 纬度

后果说明：

如果不按此约定存储，地理位置定向功能可能无法正常工作
系统 Lua 脚本中可能依赖此约定进行距离计算
务必遵循此约定，其他 UINT32 字段（索引 3-8）可自由使用

2.3.4.2 数据准备

准备符合格式要求的 JSONL（JSON Lines）文件，每行一个 JSON 对象。

数据格式示例：

{"userid":"store_001","uint32sKv":{"1":116397128,"2":39916527},"bytesKv":{"1":3,"2":150}}
{"userid":"store_002","uint32sKv":{"1":121473701,"2":31230416},"bytesKv":{"1":2,"2":200},"flagsWithExpireKv":{"1":{"flag":true}}}
{"userid":"poi_bj_hd_001","uint32sKv":{"1":116311500,"2":39978000},"bytesKv":{"3":100},"uint32sKv":{"3":5000000}}

字段说明：

字段	类型	说明	示例
`userid`	string	门店ID，客户自定义，建议使用数字或字母	`"store_001"`, `"poi_bj_001"`
`bytesKv`	map	UINT8 字段（索引 1-64，值 0-255）	`{"1":3,"2":150}`
`uint32sKv`	map	UINT32 字段（索引 1-8，值 0-4294967295）	`{"1":116397128,"2":39916527}`
`flagsWithExpireKv`	map	FLAG 字段（索引 1-4，布尔型+可选过期）	`{"1":{"flag":true,"expire":1758686629}}`

userid 格式说明：

✅ 任意字符串，无需哈希或加密
✅ 建议使用有业务意义的 ID（如门店编码、POI ID）
✅ 推荐格式：store_001, poi_bj_hd_001, shop12345
✅ 长度建议：不超过 64 字节
❌ 避免使用特殊字符（虽然技术上支持）

经纬度写入示例：

假设门店经纬度为：

经度：116.397128
纬度：39.916527

写入数据：

{
  "userid": "store_tianmen",
  "uint32sKv": {
    "1": 116397128,  // 经度 × 1000000
    "2": 39916527,   // 纬度 × 1000000
    "3": 1000,       // 其他业务字段（如：客流量）
    "4": 5           // 其他业务字段（如：评分）
  },
  "bytesKv": {
    "1": 3,   // 门店等级
    "2": 150  // 门店面积(平米)
  },
  "flagsWithExpireKv": {
    "1": {"flag": true}  // 是否营业中
  }
}

FLAG 字段过期时间格式：

{"flag": true} - 永久为 true
{"flag": false} - 永久为 false
{"flag": true, "expire": 1758686629} - 在 Unix 时间戳 1758686629 前为 true，之后为 false

2.3.4.3 写入方式

GEO 数据区支持以下写入方式，可根据数据量和使用场景选择：

方法一：使用 saastool CLI 工具

最简单的写入方式，适合开发测试和小批量数据写入。

# 写入单个文件
saastool write -ds geo -source ./stores.jsonl

# 写入目录下所有 JSONL 文件
saastool write -ds geo -source ./geo_data_dir/

# 写入前先清空所有数据（慎用）
saastool write -ds geo -source ./stores.jsonl -clear

# 指定批处理大小
saastool write -ds geo -source ./stores.jsonl -batchsize 5000

参数说明：

-ds geo：指定 GEO 数据区
-source：数据文件或目录路径
-batchsize：批处理大小（默认 10000，建议 5000-10000）
-clear：写入前清空所有数据（可选，危险操作）

方法二：使用 saashttp 包（程序集成）

在 Go 程序中使用 saashttp 包进行数据写入。

package main

import (
    "context"
    "fmt"
    "git.algo.com.cn/public/saasapi/pkg/rtapb"
    "git.algo.com.cn/public/saasapi/pkg/saashttp"
)

func main() {
    // 1. 创建客户端
    client := &saashttp.SaasClient{
        ApiUrls: saashttp.NewApiUrls(saashttp.ApiEnvDemo), // 或 ApiEnvPrd
        Auth: &saashttp.SaasAuth{
            Account: 2000,
            Token:   "your_token_here",
        },
        Client: saashttp.DefaultClient,
    }

    // 2. 准备写入数据（示例：北京两家门店）
    req := &rtapb.SaasReq{
        Write: &rtapb.Write{
            DataspaceId: "geo",
            WriteItems: []*rtapb.WriteItem{
                {
                    Userid: "store_tianmen",
                    Uint32SKv: map[uint32]uint32{
                        1: 116397128, // 经度 × 1000000
                        2: 39916527,  // 纬度 × 1000000
                        3: 1000,      // 日客流量
                    },
                    BytesKv: map[uint32]uint32{
                        1: 3,   // 门店等级
                        2: 150, // 门店面积
                    },
                    FlagsWithExpireKv: map[uint32]*rtapb.FlagWithExpire{
                        1: {Flag: true}, // 营业中
                    },
                },
                {
                    Userid: "store_wangjing",
                    Uint32SKv: map[uint32]uint32{
                        1: 116470000, // 经度
                        2: 39995000,  // 纬度
                        3: 500,       // 日客流量
                    },
                    BytesKv: map[uint32]uint32{
                        1: 2,   // 门店等级
                        2: 120, // 门店面积
                    },
                },
            },
        },
    }

    // 3. 发起写入请求
    res, err := client.Write(context.Background(), req)
    if err != nil {
        fmt.Printf("请求失败: %v\n", err)
        return
    }

    // 4. 检查返回结果
    if res.Code != 0 {
        fmt.Printf("业务错误: code=%d, status=%s\n", res.Code, res.Status)
        return
    }

    // 5. 检查失败的 userid
    if len(res.GetWrite().FailedUserid) > 0 {
        fmt.Printf("部分写入失败: %v\n", res.GetWrite().FailedUserid)
    } else {
        fmt.Println("✅ 所有数据写入成功")
    }
}

方法三：使用 saastool HTTP daemon 模式

saastool 支持以 HTTP 服务模式运行，提供简单的 HTTP 接口进行数据读写。

1. 启动 daemon 服务

export SRTA_ACCOUNT=2000
export SRTA_TOKEN=your_token_here
export SRTA_ENV=demo  # 或 prd
export SRTA_PORT=8080

saastool daemon

2. 单个门店写入（GET 请求）

# 写入门店数据（含经纬度）
curl "http://localhost:8080/write?ds=geo&userid=store_001&u32.1=116397128&u32.2=39916527&u8.1=3&u8.2=150"

# 写入前先清空该门店数据
curl "http://localhost:8080/write?ds=geo&userid=store_001&u32.1=116397128&u32.2=39916527&clear=true"

# 写入 FLAG 字段
curl "http://localhost:8080/write?ds=geo&userid=store_001&u32.1=116397128&u32.2=39916527&flag.1=true"

3. 批量写入（POST 请求）

curl -X POST "http://localhost:8080/write?ds=geo" \
  -H "Content-Type: text/plain" \
  -d "userid=store_001&u32.1=116397128&u32.2=39916527&u8.1=3" \
  -d "userid=store_002&u32.1=121473701&u32.2=31230416&u8.1=2" \
  -d "userid=store_003&u32.1=113264385&u32.2=23129112&flag.1=true"

方法四：使用 Task 任务批量写入（推荐大数据量）

Task 任务模式适用于千万级以上门店数据的批量写入，支持断点续传和并发上传。

完整流程：

步骤1：生成任务元数据

saastool task make \
  -source ./geo_stores.jsonl \
  -hash ./task.json \
  -ds geo \
  -blocksize 200M \
  -desc "门店数据批量导入"

步骤2：创建任务

saastool task create -hash ./task.json

步骤3：上传数据分块

# 从返回结果中获取 taskSha256
saastool task upload -sha256 <taskSha256>

步骤4：执行任务

saastool task run -sha256 <taskSha256>

步骤5：查询任务状态

saastool task info -sha256 <taskSha256>

步骤6：删除任务（可选）

saastool task delete -sha256 <taskSha256>

2.3.4.4 数据验证

写入完成后，建议进行数据验证：

# 使用 saastool 读取
saastool read -ds geo -userids store_001,store_002

# 使用 HTTP daemon 读取
curl "http://localhost:8080/read?ds=geo&userid=store_001"

返回示例：

{
  "code": 0,
  "status": "ok",
  "read": {
    "readItems": [
      {
        "userid": "store_001",
        "bytesKv": {"1": 3, "2": 150},
        "uint32sKv": {"1": 116397128, "2": 39916527, "3": 1000},
        "flagsKv": {"1": true}
      }
    ]
  }
}

验证经纬度：

经度 = 116397128 ÷ 1000000 = 116.397128
纬度 = 39916527 ÷ 1000000 = 39.916527

2.3.4.5 注意事项

userid 格式：
- GEO 区的 userid 为客户自定义的门店 ID，可以是任意字符串
- 建议使用数字或字母组合，避免特殊字符
- 推荐格式：store_001, poi_bj_hd_001, shop12345
⚠️ 经纬度字段约定（非常重要）：
- UINT32[1] 固定存储经度（longitude × 1000000）
- UINT32[2] 固定存储纬度（latitude × 1000000）
- 不遵循此约定会导致地理位置定向功能异常
- 其他 UINT32 字段（索引 3-8）可自由使用
字段索引范围：
- UINT8 字段：索引 1-64，值范围 0-255
- UINT32 字段：索引 1-8，值范围 0-4294967295（索引 1、2 预留给经纬度）
- FLAG 字段：索引 1-4，值为布尔型
批处理大小：
- 实时写入建议单次不超过 10000 条记录
- 大批量数据（≥ 100万）建议使用 Task 模式
增量写入：
- 默认为增量写入（覆盖指定字段）
- 使用 -clear 参数可先清空该门店数据再写入
清空数据区：
- 使用 saastool resetds -ds geo 可清空整个 GEO 数据区（慎用）
- 每天限制调用 5 次
Task 任务限制：
- 同一时间只能运行一个任务
- 任务运行期间，实时写入接口会被阻塞

2.3.4.6 最佳实践

经纬度数据规范：
- 始终将经度存入 UINT32[1]，纬度存入 UINT32[2]
- 确保经纬度精度为 6 位小数（乘以 1000000 后取整）
- 经度范围：-180 ~ 180（存储值：0 ~ 360000000）
- 纬度范围：-90 ~ 90（存储值：0 ~ 180000000）
- 处理负数经纬度时加上偏移量（如经度 -116.397128 存储为：(-116.397128 + 180) × 1000000 = 63602872）
门店 ID 规划：
- 使用统一的命名规范（如：store_{city}_{id}）
- 保持 ID 长度适中（建议不超过 32 字符）
- 避免使用容易混淆的字符（如：0 vs O, 1 vs l）
字段规划：
- 提前规划好 UINT8 和 UINT32 字段的用途
- 建议维护字段索引文档（示例：U8[1]=门店等级, U8[2]=门店面积）
- UINT32[3-8] 可用于存储业务指标（如客流量、评分）
数据验证：
- 写入后使用 read 命令验证数据正确性
- 检查 failed_userid 并重试失败的记录
- 定期抽查门店数据的经纬度是否正确
错误处理：
- API 返回的 failed_userid 可能包含格式错误或系统错误
- 建议记录失败的门店 ID 并分析原因
- 对失败的记录进行重试或记录日志
性能优化：
- 小批量数据（< 10万）使用 CLI 或 API 实时写入
- 大批量数据（≥ 100万）使用 Task 模式
- Task 模式建议在业务低峰期执行

2.3.4.7 GEO 区与其他数据区对比

对比项	GEO 数据区	DID 数据区	WUID 数据区
用户标识	门店 ID（原始值）	设备 ID 的 MD5	手机号哈希或 OpenID
userid 格式	任意字符串	32位十六进制 MD5	32位哈希或 OpenID 原文
必填参数	无	无	`hashtype` 或 `appid`
特殊字段	UINT32[1,2] 预留给经纬度	无特殊约定	无特殊约定
数据格式	无需哈希或加密	必须计算 MD5	手机号需哈希，OpenID 不需要
适用场景	门店、POI、地理位置数据	设备用户数据	手机号或微信生态用户数据

选择建议：

门店、POI、地理位置场景 → 使用 GEO 数据区
需要存储设备用户行为 → 使用 DID 数据区
需要手机号或微信用户数据 → 使用 WUID 数据区

2.3.4.8 经纬度转换工具函数

为了方便开发者使用，提供以下经纬度转换工具函数：

Go 语言示例：

// 经纬度转 UINT32 存储值
func LatLngToUint32(lat, lng float64) (latInt, lngInt uint32) {
    // 经度：-180 ~ 180 转为 0 ~ 360000000
    lngInt = uint32((lng + 180) * 1000000)
    // 纬度：-90 ~ 90 转为 0 ~ 180000000
    latInt = uint32((lat + 90) * 1000000)
    return
}

// UINT32 存储值转经纬度
func Uint32ToLatLng(latInt, lngInt uint32) (lat, lng float64) {
    lng = float64(lngInt)/1000000 - 180
    lat = float64(latInt)/1000000 - 90
    return
}

// 使用示例
func main() {
    // 北京天安门坐标
    lat, lng := 39.916527, 116.397128
    
    // 转换为存储值
    latInt, lngInt := LatLngToUint32(lat, lng)
    fmt.Printf("经度存储值: %d, 纬度存储值: %d\n", lngInt, latInt)
    // 输出: 经度存储值: 296397128, 纬度存储值: 129916527
    
    // 反向转换验证
    lat2, lng2 := Uint32ToLatLng(latInt, lngInt)
    fmt.Printf("经度: %.6f, 纬度: %.6f\n", lng2, lat2)
    // 输出: 经度: 116.397128, 纬度: 39.916527
}

Python 示例：

def latlng_to_uint32(lat, lng):
    """经纬度转 UINT32 存储值"""
    lng_int = int((lng + 180) * 1000000)
    lat_int = int((lat + 90) * 1000000)
    return lat_int, lng_int

def uint32_to_latlng(lat_int, lng_int):
    """UINT32 存储值转经纬度"""
    lng = lng_int / 1000000 - 180
    lat = lat_int / 1000000 - 90
    return lat, lng

# 使用示例
lat, lng = 39.916527, 116.397128
lat_int, lng_int = latlng_to_uint32(lat, lng)
print(f"经度存储值: {lng_int}, 纬度存储值: {lat_int}")
# 输出: 经度存储值: 296397128, 纬度存储值: 129916527

# 反向转换验证
lat2, lng2 = uint32_to_latlng(lat_int, lng_int)
print(f"经度: {lng2:.6f}, 纬度: {lat2:.6f}")
# 输出: 经度: 116.397128, 纬度: 39.916527

2.3.5 IP城市数据写入(GEOIP区)

GEOIP 数据区用于存储基于用户 IP 地址所在城市的用户数据。与其他数据区不同，GEOIP 数据区的 userid 使用中国行政区划码（6位数字编码）作为用户标识。本节介绍 IP 城市数据写入的完整流程。

2.3.5.1 检查数据区开通状态

在写入数据前，先使用 saastool info 命令检查是否已开通 GEOIP 数据区。

saastool info

如显示的 dataspace 节点下有 geoip 字段,则表明已开通 GEOIP 数据区；若不存在，需联系管理员开通。

Info res: {
  "dataspace": {
    "geoip": [
      "geoip",
      "20010801"
    ]
  },
  "targetId": []
}

"geoip": 数据空间别名
"20010801": 数据空间数字ID

行政区划码说明

GEOIP 区使用中国行政区划码作为 userid，行政区划码采用 6 位数字编码：

编码规则：

前 2 位：省级（省、自治区、直辖市）
中间 2 位：地级（市、地区、自治州）
后 2 位：县级（县、区、县级市）

示例：

110000：北京市（省级）
130100：河北省石家庄市（地级市）
440300：广东省深圳市（地级市）
100000：全国（国家级，用于默认数据）

支持格式：

6位数字行政区划码（推荐）："130100", "440300"
"省:市" 格式："河北省:石家庄市", "广东省:深圳市"
单省份名称："河北省", "广东省"（会自动转换为省级代码）

完整的行政区划码映射表请参考：附录：行政区划码映射表

2.3.5.2 数据准备

准备符合格式要求的 JSONL（JSON Lines）文件，每行一个 JSON 对象。

数据格式示例：

{"userid":"110000","bytesKv":{"1":5,"2":200},"uint32sKv":{"1":1000000},"flagsWithExpireKv":{"1":{"flag":true}}}
{"userid":"130100","bytesKv":{"1":3,"2":150},"uint32sKv":{"1":500000}}
{"userid":"440300","bytesKv":{"1":5,"2":250},"uint32sKv":{"1":2000000},"flagsWithExpireKv":{"2":{"flag":true,"expire":1758686629}}}
{"userid":"河北省:石家庄市","bytesKv":{"1":3,"2":150}}
{"userid":"广东省:深圳市","bytesKv":{"1":5,"2":250}}

字段说明：

字段	类型	说明	示例
`userid`	string	行政区划码（6位数字）或 "省:市" 格式	`"110000"`, `"河北省:石家庄市"`
`bytesKv`	map	UINT8 字段（索引 1-64，值 0-255）	`{"1":5,"2":200}`
`uint32sKv`	map	UINT32 字段（索引 1-8，值 0-4294967295）	`{"1":1000000}`
`flagsWithExpireKv`	map	FLAG 字段（索引 1-4，布尔型+可选过期）	`{"1":{"flag":true,"expire":1758686629}}`

userid 格式说明：

推荐格式：使用 6 位数字行政区划码

{"userid":"110000","bytesKv":{"1":5}}  // 北京市
{"userid":"130100","bytesKv":{"1":3}}  // 河北省石家庄市
{"userid":"440300","bytesKv":{"1":5}}  // 广东省深圳市

"省:市" 格式：会自动转换为对应的行政区划码

{"userid":"北京:北京","bytesKv":{"1":5}}        // 自动转为 110000
{"userid":"河北省:石家庄市","bytesKv":{"1":3}}  // 自动转为 130100
{"userid":"广东省:深圳市","bytesKv":{"1":5}}    // 自动转为 440300

单省份格式：会转换为省级代码

{"userid":"北京","bytesKv":{"1":5}}      // 自动转为 110000
{"userid":"河北省","bytesKv":{"1":3}}    // 自动转为 130000
{"userid":"广东省","bytesKv":{"1":5}}    // 自动转为 440000

数据写入示例（业务场景）：

假设要为不同城市的用户设置推荐权重和投放预算：

{"userid":"110000","bytesKv":{"1":10,"2":5},"uint32sKv":{"1":5000000},"flagsWithExpireKv":{"1":{"flag":true}}}
{"userid":"310000","bytesKv":{"1":10,"2":5},"uint32sKv":{"1":4500000},"flagsWithExpireKv":{"1":{"flag":true}}}
{"userid":"440300","bytesKv":{"1":9,"2":4},"uint32sKv":{"1":3000000},"flagsWithExpireKv":{"1":{"flag":true}}}
{"userid":"130100","bytesKv":{"1":7,"2":3},"uint32sKv":{"1":1000000},"flagsWithExpireKv":{"1":{"flag":true}}}

字段含义示例：

bytesKv.1：城市推荐权重（1-10）
bytesKv.2：城市等级（1-5）
uint32sKv.1：投放预算（单位：分）
flagsWithExpireKv.1：是否启用投放

2.3.5.3 写入方式

GEOIP 数据区支持以下写入方式，可根据数据量和使用场景选择：

方法一：使用 saastool CLI 工具

最简单的写入方式，适合开发测试和小批量数据写入。

# 写入单个文件
saastool write -ds geoip -source ./geoip_data.jsonl

# 写入目录下所有 JSONL 文件
saastool write -ds geoip -source ./geoip_data_dir/

# 写入前先清空所有数据（慎用）
saastool write -ds geoip -source ./geoip_data.jsonl -clear

# 指定批处理大小
saastool write -ds geoip -source ./geoip_data.jsonl -batchsize 5000

参数说明：

-ds geoip：指定 GEOIP 数据区
-source：数据文件或目录路径
-batchsize：批处理大小（默认 10000，建议 5000-10000）
-clear：写入前清空所有数据（可选，危险操作）

方法二：使用 saashttp 包（程序集成）

在 Go 程序中使用 saashttp 包进行数据写入。

package main

import (
    "context"
    "fmt"
    "git.algo.com.cn/public/saasapi/pkg/rtapb"
    "git.algo.com.cn/public/saasapi/pkg/saashttp"
)

func main() {
    // 1. 创建客户端
    client := &saashttp.SaasClient{
        ApiUrls: saashttp.NewApiUrls(saashttp.ApiEnvDemo), // 或 ApiEnvPrd
        Auth: &saashttp.SaasAuth{
            Account: 2000,
            Token:   "your_token_here",
        },
        Client: saashttp.DefaultClient,
    }

    // 2. 准备写入数据（示例：北京、上海、深圳、石家庄）
    req := &rtapb.SaasReq{
        Write: &rtapb.Write{
            DataspaceId: "geoip",
            WriteItems: []*rtapb.WriteItem{
                {
                    Userid: "110000", // 北京市
                    BytesKv: map[uint32]uint32{
                        1: 10, // 推荐权重
                        2: 5,  // 城市等级
                    },
                    Uint32SKv: map[uint32]uint32{
                        1: 5000000, // 投放预算（分）
                    },
                    FlagsWithExpireKv: map[uint32]*rtapb.FlagWithExpire{
                        1: {Flag: true}, // 启用投放
                    },
                },
                {
                    Userid: "310000", // 上海市
                    BytesKv: map[uint32]uint32{
                        1: 10,
                        2: 5,
                    },
                    Uint32SKv: map[uint32]uint32{
                        1: 4500000,
                    },
                    FlagsWithExpireKv: map[uint32]*rtapb.FlagWithExpire{
                        1: {Flag: true},
                    },
                },
                {
                    Userid: "河北省:石家庄市", // 也支持 "省:市" 格式
                    BytesKv: map[uint32]uint32{
                        1: 7,
                        2: 3,
                    },
                    Uint32SKv: map[uint32]uint32{
                        1: 1000000,
                    },
                },
            },
        },
    }

    // 3. 发起写入请求
    res, err := client.Write(context.Background(), req)
    if err != nil {
        fmt.Printf("请求失败: %v\n", err)
        return
    }

    // 4. 检查返回结果
    if res.Code != 0 {
        fmt.Printf("业务错误: code=%d, status=%s\n", res.Code, res.Status)
        return
    }

    // 5. 检查失败的 userid
    if len(res.GetWrite().FailedUserid) > 0 {
        fmt.Printf("部分写入失败: %v\n", res.GetWrite().FailedUserid)
    } else {
        fmt.Println("✅ 所有数据写入成功")
    }
}

方法三：使用 saastool HTTP daemon 模式

saastool 支持以 HTTP 服务模式运行，提供简单的 HTTP 接口进行数据读写。

1. 启动 daemon 服务

export SRTA_ACCOUNT=2000
export SRTA_TOKEN=your_token_here
export SRTA_ENV=demo  # 或 prd
export SRTA_PORT=8080

saastool daemon

2. 单个城市写入（GET 请求）

# 使用行政区划码写入（推荐）
curl "http://localhost:8080/write?ds=geoip&userid=110000&u8.1=10&u8.2=5&u32.1=5000000&flag.1=true"

# 使用 "省:市" 格式
curl "http://localhost:8080/write?ds=geoip&userid=河北省:石家庄市&u8.1=7&u8.2=3&u32.1=1000000"

# 写入前先清空该城市数据
curl "http://localhost:8080/write?ds=geoip&userid=110000&u8.1=10&clear=true"

3. 批量写入（POST 请求）

curl -X POST "http://localhost:8080/write?ds=geoip" \
  -H "Content-Type: text/plain" \
  -d "userid=110000&u8.1=10&u8.2=5&u32.1=5000000" \
  -d "userid=310000&u8.1=10&u8.2=5&u32.1=4500000" \
  -d "userid=440300&u8.1=9&u8.2=4&u32.1=3000000" \
  -d "userid=130100&u8.1=7&u8.2=3&u32.1=1000000"

方法四：使用 Task 任务批量写入（推荐大数据量）

Task 任务模式适用于大量城市数据的批量写入，支持断点续传和并发上传。

完整流程：

步骤1：生成任务元数据

saastool task make \
  -source ./geoip_cities.jsonl \
  -hash ./task.json \
  -ds geoip \
  -blocksize 200M \
  -desc "IP城市数据批量导入"

步骤2：创建任务

saastool task create -hash ./task.json

步骤3：上传数据分块

# 从返回结果中获取 taskSha256
saastool task upload -sha256 <taskSha256>

步骤4：执行任务

saastool task run -sha256 <taskSha256>

步骤5：查询任务状态

saastool task info -sha256 <taskSha256>

步骤6：删除任务（可选）

saastool task delete -sha256 <taskSha256>

2.3.5.4 数据验证

写入完成后，建议进行数据验证：

# 使用 saastool 读取（使用行政区划码）
saastool read -ds geoip -userids 110000,130100,440300

# 使用 saastool 读取（使用 "省:市" 格式）
saastool read -ds geoip -userids "北京:北京,河北省:石家庄市"

# 使用 HTTP daemon 读取
curl "http://localhost:8080/read?ds=geoip&userid=110000"

返回示例：

{
  "code": 0,
  "status": "ok",
  "read": {
    "readItems": [
      {
        "userid": "110000",
        "bytesKv": {"1": 10, "2": 5},
        "uint32sKv": {"1": 5000000},
        "flagsKv": {"1": true}
      },
      {
        "userid": "130100",
        "bytesKv": {"1": 7, "2": 3},
        "uint32sKv": {"1": 1000000},
        "flagsKv": {}
      }
    ]
  }
}

2.3.5.5 查询行政区划码

系统提供了 admincode 命令用于查询行政区划码：

# 查询所有行政区划码
saastool admincode list

# 查询结果示例
{
  "adminCodes": [
    {
      "code": "110000",
      "province": "北京市",
      "city": "北京市"
    },
    {
      "code": "130100",
      "province": "河北省",
      "city": "石家庄市"
    },
    {
      "code": "440300",
      "province": "广东省",
      "city": "深圳市"
    }
  ]
}

完整的行政区划码映射表请参考：附录：行政区划码映射表

2.3.5.6 注意事项

userid 格式要求：
- ✅ 推荐使用 6 位数字行政区划码："110000", "130100"
- ✅ 支持 "省:市" 格式："河北省:石家庄市"（会自动转换）
- ✅ 支持单省份："河北省"（会转换为省级代码）
- ❌ 不支持任意字符串（必须能转换为有效的行政区划码）
行政区划码转换：
- 系统会自动将 "省:市" 格式转换为 6 位数字行政区划码
- 转换失败的 userid 会在 API 返回的 failed_userid 中
- 建议提前验证行政区划码的有效性
字段索引范围：
- UINT8 字段：索引 1-64，值范围 0-255
- UINT32 字段：索引 1-8，值范围 0-4294967295
- FLAG 字段：索引 1-4，值为布尔型
批处理大小：
- 实时写入建议单次不超过 10000 条记录
- GEOIP 数据通常不会超过数千条（全国城市数量有限）
增量写入：
- 默认为增量写入（覆盖指定字段）
- 使用 -clear 参数可先清空该城市数据再写入
清空数据区：
- 使用 saastool resetds -ds geoip 可清空整个 GEOIP 数据区（慎用）
- 每天限制调用 5 次
Lua 查询回退机制：
- 在 Lua 脚本中查询 GEOIP 数据时，如果找不到城市级数据，会自动回退到省级
- 如果省级也找不到，会回退到国家级代码 100000
- 建议为常用省份和全国设置默认数据

2.3.5.7 最佳实践

数据分层策略：
- 国家级（100000）：设置全国默认数据
- 省级（如 130000 河北省）：设置省级默认数据
- 市级（如 130100 石家庄市）：设置具体城市数据
- Lua 查询时会自动回退，确保总能获取到数据
行政区划码规范：
- 优先使用 6 位数字行政区划码，避免使用 "省:市" 格式（减少转换开销）
- 提前验证行政区划码的有效性（使用 saastool admincode list 查询）
- 维护行政区划码与业务含义的映射文档
字段规划：
- 提前规划好 UINT8 和 UINT32 字段的用途
- 建议维护字段索引文档（示例：U8[1]=推荐权重, U32[1]=投放预算）
- 考虑字段的扩展性，为未来需求预留字段
数据验证：
- 写入后使用 read 命令验证数据正确性
- 检查 failed_userid 并重试失败的记录
- 定期抽查城市数据是否正确
错误处理：
- API 返回的 failed_userid 可能包含无效的行政区划码
- 建议记录失败的 userid 并分析原因（是否为无效城市）
- 对失败的记录进行重试或记录日志
性能优化：
- GEOIP 数据量通常较小（全国城市数千个），可使用 CLI 或 API 实时写入
- 如果数据量较大（> 10万），使用 Task 模式
- 建议在业务低峰期执行批量更新
默认数据设置：
- 务必设置国家级默认数据（100000），作为最终兜底
- 为一线城市和重点省份设置具体数据
- 其他城市可使用省级或国家级数据

2.3.5.8 GEOIP 区与其他数据区对比

对比项	GEOIP 数据区	GEO 数据区	DID 数据区
用户标识	行政区划码（6位数字）	门店 ID（原始值）	设备 ID 的 MD5
userid 格式	`"110000"` 或 `"北京:北京"`	任意字符串	32位十六进制 MD5
userid 转换	✅ 支持 "省:市" 自动转换	❌ 不需要转换	❌ 必须预先计算 MD5
数据量级	小（数千条，全国城市有限）	中等（数万-数百万门店）	大（亿级设备用户）
适用场景	基于用户 IP 所在城市定向	门店、POI 地理位置定向	设备用户行为数据
Lua 查询	支持自动回退（市→省→国家）	不支持回退	不支持回退

选择建议：

需要基于用户 IP 所在城市定向 → 使用 GEOIP 数据区
需要门店、POI 地理位置定向 → 使用 GEO 数据区
需要存储设备用户行为 → 使用 DID 数据区

2.3.5.9 行政区划码示例

以下是常用城市的行政区划码示例：

省份	城市	行政区划码	使用场景
全国	全国	`100000`	国家级默认数据
北京市	北京市	`110000`	直辖市
上海市	上海市	`310000`	直辖市
天津市	天津市	`120000`	直辖市
重庆市	重庆市	`500100`	直辖市
河北省	河北省	`130000`	省级默认
河北省	石家庄市	`130100`	省会城市
广东省	广东省	`440000`	省级默认
广东省	广州市	`440100`	省会城市
广东省	深圳市	`440300`	一线城市
浙江省	杭州市	`330100`	省会城市
江苏省	南京市	`320100`	省会城市
四川省	成都市	`510100`	省会城市

完整的行政区划码映射表请参考：附录：行政区划码映射表

2.3.6 常住城市数据写入(GEOFAC区)

GEOFAC（Frequently Active City）数据区用于存储基于用户常住城市的用户数据。与 GEOIP 数据区类似，GEOFAC 数据区也使用中国行政区划码（6位数字编码）作为用户标识。本节介绍常住城市数据写入的完整流程。

2.3.6.1 检查数据区开通状态

在写入数据前，先使用 saastool info 命令检查是否已开通 GEOFAC 数据区。

saastool info

如显示的 dataspace 节点下有 geofac 字段，则表明已开通 GEOFAC 数据区；若不存在，需联系管理员开通。

Info res: {
  "dataspace": {
    "geofac": [
      "geofac",
      "20010901"
    ]
  },
  "targetId": []
}

"geofac": 数据空间别名
"20010901": 数据空间数字ID

行政区划码说明

GEOFAC 区使用中国行政区划码作为 userid，行政区划码采用 6 位数字编码：

编码规则：

前 2 位：省级（省、自治区、直辖市）
中间 2 位：地级（市、地区、自治州）
后 2 位：县级（县、区、县级市）

示例：

110000：北京市（省级）
130100：河北省石家庄市（地级市）
440300：广东省深圳市（地级市）
100000：全国（国家级，用于默认数据）

支持格式：

6位数字行政区划码（推荐）："130100", "440300"
"省:市" 格式："河北省:石家庄市", "广东省:深圳市"
单省份名称："河北省", "广东省"（会自动转换为省级代码）

完整的行政区划码映射表请参考：附录：行政区划码映射表

2.3.6.2 GEOFAC 与 GEOIP 的区别

虽然两者都使用行政区划码，但应用场景和数据含义不同：

对比项	GEOFAC（常住城市）	GEOIP（IP城市）
数据来源	用户常住城市（通过用户画像、GPS、历史行为分析）	用户当前 IP 所在城市
稳定性	稳定（常住地一般不变）	不稳定（用户可能出差、旅行）
准确性	高（需要用户画像数据支持）	中（IP 定位可能有偏差）
适用场景	长期用户画像、本地化推荐	实时地理位置定向、临时活动推广
数据更新频率	低（月度或季度更新）	高（每次请求实时查询）

选择建议：

需要基于用户常住地的长期投放策略 → 使用 GEOFAC 数据区
需要基于用户当前位置的实时投放 → 使用 GEOIP 数据区
可以同时使用两个数据区，在 Lua 脚本中实现更精准的定向逻辑

2.3.6.3 数据准备

准备符合格式要求的 JSONL（JSON Lines）文件，每行一个 JSON 对象。

数据格式示例：

{"userid":"110000","bytesKv":{"1":8,"2":100},"uint32sKv":{"1":3000000},"flagsWithExpireKv":{"1":{"flag":true}}}
{"userid":"130100","bytesKv":{"1":5,"2":80},"uint32sKv":{"1":800000}}
{"userid":"440300","bytesKv":{"1":9,"2":120},"uint32sKv":{"1":5000000},"flagsWithExpireKv":{"2":{"flag":true,"expire":1758686629}}}
{"userid":"河北省:石家庄市","bytesKv":{"1":5,"2":80}}
{"userid":"广东省:深圳市","bytesKv":{"1":9,"2":120}}

字段说明：

字段	类型	说明	示例
`userid`	string	行政区划码（6位数字）或 "省:市" 格式	`"110000"`, `"河北省:石家庄市"`
`bytesKv`	map	UINT8 字段（索引 1-64，值 0-255）	`{"1":8,"2":100}`
`uint32sKv`	map	UINT32 字段（索引 1-8，值范围 0-4294967295）	`{"1":3000000}`
`flagsWithExpireKv`	map	FLAG 字段（索引 1-4，布尔型+可选过期）	`{"1":{"flag":true,"expire":1758686629}}`

userid 格式说明（与 GEOIP 相同）：

推荐格式：使用 6 位数字行政区划码

{"userid":"110000","bytesKv":{"1":8}}  // 北京市
{"userid":"130100","bytesKv":{"1":5}}  // 河北省石家庄市
{"userid":"440300","bytesKv":{"1":9}}  // 广东省深圳市

"省:市" 格式：会自动转换为对应的行政区划码

{"userid":"北京:北京","bytesKv":{"1":8}}        // 自动转为 110000
{"userid":"河北省:石家庄市","bytesKv":{"1":5}}  // 自动转为 130100
{"userid":"广东省:深圳市","bytesKv":{"1":9}}    // 自动转为 440300

单省份格式：会转换为省级代码

{"userid":"北京","bytesKv":{"1":8}}      // 自动转为 110000
{"userid":"河北省","bytesKv":{"1":5}}    // 自动转为 130000
{"userid":"广东省","bytesKv":{"1":9}}    // 自动转为 440000

数据写入示例（业务场景）：

假设要为不同常住城市的用户设置推荐权重和投放策略：

{"userid":"110000","bytesKv":{"1":10,"2":100,"3":5},"uint32sKv":{"1":8000000},"flagsWithExpireKv":{"1":{"flag":true}}}
{"userid":"310000","bytesKv":{"1":10,"2":100,"3":5},"uint32sKv":{"1":7000000},"flagsWithExpireKv":{"1":{"flag":true}}}
{"userid":"440300","bytesKv":{"1":9,"2":95,"3":4},"uint32sKv":{"1":6000000},"flagsWithExpireKv":{"1":{"flag":true}}}
{"userid":"510100","bytesKv":{"1":8,"2":90,"3":4},"uint32sKv":{"1":4000000},"flagsWithExpireKv":{"1":{"flag":true}}}
{"userid":"130100","bytesKv":{"1":7,"2":80,"3":3},"uint32sKv":{"1":2000000},"flagsWithExpireKv":{"1":{"flag":true}}}

字段含义示例：

bytesKv.1：常住地推荐权重（1-10）
bytesKv.2：用户活跃度（0-100）
bytesKv.3：城市消费等级（1-5）
uint32sKv.1：月度投放预算（单位：分）
flagsWithExpireKv.1：是否启用常住地投放

2.3.6.4 写入方式

GEOFAC 数据区支持以下写入方式，可根据数据量和使用场景选择：

方法一：使用 saastool CLI 工具

最简单的写入方式，适合开发测试和小批量数据写入。

# 写入单个文件
saastool write -ds geofac -source ./geofac_data.jsonl

# 写入目录下所有 JSONL 文件
saastool write -ds geofac -source ./geofac_data_dir/

# 写入前先清空所有数据（慎用）
saastool write -ds geofac -source ./geofac_data.jsonl -clear

# 指定批处理大小
saastool write -ds geofac -source ./geofac_data.jsonl -batchsize 5000

参数说明：

-ds geofac：指定 GEOFAC 数据区
-source：数据文件或目录路径
-batchsize：批处理大小（默认 10000，建议 5000-10000）
-clear：写入前清空所有数据（可选，危险操作）

方法二：使用 saashttp 包（程序集成）

在 Go 程序中使用 saashttp 包进行数据写入。

package main

import (
    "context"
    "fmt"
    "git.algo.com.cn/public/saasapi/pkg/rtapb"
    "git.algo.com.cn/public/saasapi/pkg/saashttp"
)

func main() {
    // 1. 创建客户端
    client := &saashttp.SaasClient{
        ApiUrls: saashttp.NewApiUrls(saashttp.ApiEnvDemo), // 或 ApiEnvPrd
        Auth: &saashttp.SaasAuth{
            Account: 2000,
            Token:   "your_token_here",
        },
        Client: saashttp.DefaultClient,
    }

    // 2. 准备写入数据（示例：一线城市常住地数据）
    req := &rtapb.SaasReq{
        Write: &rtapb.Write{
            DataspaceId: "geofac",
            WriteItems: []*rtapb.WriteItem{
                {
                    Userid: "110000", // 北京市
                    BytesKv: map[uint32]uint32{
                        1: 10,  // 推荐权重
                        2: 100, // 用户活跃度
                        3: 5,   // 消费等级
                    },
                    Uint32SKv: map[uint32]uint32{
                        1: 8000000, // 月度预算（分）
                    },
                    FlagsWithExpireKv: map[uint32]*rtapb.FlagWithExpire{
                        1: {Flag: true}, // 启用常住地投放
                    },
                },
                {
                    Userid: "310000", // 上海市
                    BytesKv: map[uint32]uint32{
                        1: 10,
                        2: 100,
                        3: 5,
                    },
                    Uint32SKv: map[uint32]uint32{
                        1: 7000000,
                    },
                    FlagsWithExpireKv: map[uint32]*rtapb.FlagWithExpire{
                        1: {Flag: true},
                    },
                },
                {
                    Userid: "河北省:石家庄市", // 也支持 "省:市" 格式
                    BytesKv: map[uint32]uint32{
                        1: 7,
                        2: 80,
                        3: 3,
                    },
                    Uint32SKv: map[uint32]uint32{
                        1: 2000000,
                    },
                },
            },
        },
    }

    // 3. 发起写入请求
    res, err := client.Write(context.Background(), req)
    if err != nil {
        fmt.Printf("请求失败: %v\n", err)
        return
    }

    // 4. 检查返回结果
    if res.Code != 0 {
        fmt.Printf("业务错误: code=%d, status=%s\n", res.Code, res.Status)
        return
    }

    // 5. 检查失败的 userid
    if len(res.GetWrite().FailedUserid) > 0 {
        fmt.Printf("部分写入失败: %v\n", res.GetWrite().FailedUserid)
    } else {
        fmt.Println("✅ 所有数据写入成功")
    }
}

方法三：使用 saastool HTTP daemon 模式

saastool 支持以 HTTP 服务模式运行，提供简单的 HTTP 接口进行数据读写。

1. 启动 daemon 服务

export SRTA_ACCOUNT=2000
export SRTA_TOKEN=your_token_here
export SRTA_ENV=demo  # 或 prd
export SRTA_PORT=8080

saastool daemon

2. 单个城市写入（GET 请求）

# 使用行政区划码写入（推荐）
curl "http://localhost:8080/write?ds=geofac&userid=110000&u8.1=10&u8.2=100&u32.1=8000000&flag.1=true"

# 使用 "省:市" 格式
curl "http://localhost:8080/write?ds=geofac&userid=河北省:石家庄市&u8.1=7&u8.2=80&u32.1=2000000"

# 写入前先清空该城市数据
curl "http://localhost:8080/write?ds=geofac&userid=110000&u8.1=10&clear=true"

3. 批量写入（POST 请求）

curl -X POST "http://localhost:8080/write?ds=geofac" \
  -H "Content-Type: text/plain" \
  -d "userid=110000&u8.1=10&u8.2=100&u32.1=8000000" \
  -d "userid=310000&u8.1=10&u8.2=100&u32.1=7000000" \
  -d "userid=440300&u8.1=9&u8.2=95&u32.1=6000000" \
  -d "userid=130100&u8.1=7&u8.2=80&u32.1=2000000"

方法四：使用 Task 任务批量写入（推荐大数据量）

Task 任务模式适用于大量城市数据的批量写入，支持断点续传和并发上传。

完整流程：

步骤1：生成任务元数据

saastool task make \
  -source ./geofac_cities.jsonl \
  -hash ./task.json \
  -ds geofac \
  -blocksize 200M \
  -desc "常住城市数据批量导入"

步骤2：创建任务

saastool task create -hash ./task.json

步骤3：上传数据分块

# 从返回结果中获取 taskSha256
saastool task upload -sha256 <taskSha256>

步骤4：执行任务

saastool task run -sha256 <taskSha256>

步骤5：查询任务状态

saastool task info -sha256 <taskSha256>

步骤6：删除任务（可选）

saastool task delete -sha256 <taskSha256>

2.3.6.5 数据验证

写入完成后，建议进行数据验证：

# 使用 saastool 读取（使用行政区划码）
saastool read -ds geofac -userids 110000,130100,440300

# 使用 saastool 读取（使用 "省:市" 格式）
saastool read -ds geofac -userids "北京:北京,河北省:石家庄市"

# 使用 HTTP daemon 读取
curl "http://localhost:8080/read?ds=geofac&userid=110000"

返回示例：

{
  "code": 0,
  "status": "ok",
  "read": {
    "readItems": [
      {
        "userid": "110000",
        "bytesKv": {"1": 10, "2": 100, "3": 5},
        "uint32sKv": {"1": 8000000},
        "flagsKv": {"1": true}
      },
      {
        "userid": "130100",
        "bytesKv": {"1": 7, "2": 80, "3": 3},
        "uint32sKv": {"1": 2000000},
        "flagsKv": {}
      }
    ]
  }
}

2.3.6.6 查询行政区划码

系统提供了 admincode 命令用于查询行政区划码：

# 查询所有行政区划码
saastool admincode list

# 查询结果示例
{
  "adminCodes": [
    {
      "code": "110000",
      "province": "北京市",
      "city": "北京市"
    },
    {
      "code": "130100",
      "province": "河北省",
      "city": "石家庄市"
    },
    {
      "code": "440300",
      "province": "广东省",
      "city": "深圳市"
    }
  ]
}

完整的行政区划码映射表请参考：附录：行政区划码映射表

2.3.6.7 注意事项

userid 格式要求（与 GEOIP 相同）：
- ✅ 推荐使用 6 位数字行政区划码："110000", "130100"
- ✅ 支持 "省:市" 格式："河北省:石家庄市"（会自动转换）
- ✅ 支持单省份："河北省"（会转换为省级代码）
- ❌ 不支持任意字符串（必须能转换为有效的行政区划码）
行政区划码转换：
- 系统会自动将 "省:市" 格式转换为 6 位数字行政区划码
- 转换失败的 userid 会在 API 返回的 failed_userid 中
- 建议提前验证行政区划码的有效性
字段索引范围：
- UINT8 字段：索引 1-64，值范围 0-255
- UINT32 字段：索引 1-8，值范围 0-4294967295
- FLAG 字段：索引 1-4，值为布尔型
批处理大小：
- 实时写入建议单次不超过 10000 条记录
- GEOFAC 数据通常不会超过数千条（全国城市数量有限）
增量写入：
- 默认为增量写入（覆盖指定字段）
- 使用 -clear 参数可先清空该城市数据再写入
清空数据区：
- 使用 saastool resetds -ds geofac 可清空整个 GEOFAC 数据区（慎用）
- 每天限制调用 5 次
Lua 查询回退机制：
- 在 Lua 脚本中查询 GEOFAC 数据时，如果找不到城市级数据，会自动回退到省级
- 如果省级也找不到，会回退到国家级代码 100000
- 建议为常用省份和全国设置默认数据

2.3.6.8 最佳实践

数据分层策略（与 GEOIP 相同）：
- 国家级（100000）：设置全国默认数据
- 省级（如 130000 河北省）：设置省级默认数据
- 市级（如 130100 石家庄市）：设置具体城市数据
- Lua 查询时会自动回退，确保总能获取到数据
行政区划码规范：
- 优先使用 6 位数字行政区划码，避免使用 "省:市" 格式（减少转换开销）
- 提前验证行政区划码的有效性（使用 saastool admincode list 查询）
- 维护行政区划码与业务含义的映射文档
字段规划：
- 提前规划好 UINT8 和 UINT32 字段的用途
- 建议维护字段索引文档（示例：U8[1]=推荐权重, U8[2]=活跃度, U32[1]=月度预算）
- 考虑字段的扩展性，为未来需求预留字段
- GEOFAC 与 GEOIP 可使用不同的字段索引，避免混淆
数据验证：
- 写入后使用 read 命令验证数据正确性
- 检查 failed_userid 并重试失败的记录
- 定期抽查城市数据是否正确
错误处理：
- API 返回的 failed_userid 可能包含无效的行政区划码
- 建议记录失败的 userid 并分析原因（是否为无效城市）
- 对失败的记录进行重试或记录日志
性能优化：
- GEOFAC 数据量通常较小（全国城市数千个），可使用 CLI 或 API 实时写入
- 如果数据量较大（> 10万），使用 Task 模式
- 建议在业务低峰期执行批量更新
默认数据设置：
- 务必设置国家级默认数据（100000），作为最终兜底
- 为一线城市和重点省份设置具体数据
- 其他城市可使用省级或国家级数据
与 GEOIP 配合使用：
- 常住地数据（GEOFAC）更新频率低，可设置更长期的投放策略
- IP 城市数据（GEOIP）实时性强，可用于临时活动和实时定向
- 在 Lua 脚本中可同时查询两个数据区，实现更精细的定向逻辑
- 示例：优先使用常住地数据，常住地无数据时使用 IP 城市数据

2.3.6.9 GEOFAC、GEOIP 与其他数据区对比

对比项	GEOFAC（常住城市）	GEOIP（IP城市）	GEO（门店）	DID（设备）
用户标识	行政区划码	行政区划码	门店 ID	设备 ID 的 MD5
userid 格式	`"110000"` 或 `"北京:北京"`	`"110000"` 或 `"北京:北京"`	任意字符串	32位十六进制 MD5
userid 转换	✅ 支持 "省:市" 自动转换	✅ 支持 "省:市" 自动转换	❌ 不需要转换	❌ 必须预先计算 MD5
数据来源	用户画像、历史行为	用户当前 IP	门店/POI 数据	设备用户行为
数据稳定性	高（常住地稳定）	低（IP 变化）	固定（门店位置）	高（设备ID固定）
数据量级	小（数千条）	小（数千条）	中等（数万-百万）	大（亿级）
适用场景	长期用户画像定向	实时地理位置定向	门店、POI 定向	设备用户行为数据
Lua 查询	支持自动回退	支持自动回退	不支持回退	不支持回退

选择建议：

需要基于用户常住地的长期策略 → 使用 GEOFAC 数据区
需要基于用户当前位置的实时投放 → 使用 GEOIP 数据区
需要门店、POI 地理位置定向 → 使用 GEO 数据区
需要存储设备用户行为 → 使用 DID 数据区

2.3.6.10 行政区划码示例

以下是常用城市的行政区划码示例（与 GEOIP 相同）：

省份	城市	行政区划码	使用场景
全国	全国	`100000`	国家级默认数据
北京市	北京市	`110000`	直辖市
上海市	上海市	`310000`	直辖市
天津市	天津市	`120000`	直辖市
重庆市	重庆市	`500100`	直辖市
河北省	河北省	`130000`	省级默认
河北省	石家庄市	`130100`	省会城市
广东省	广东省	`440000`	省级默认
广东省	广州市	`440100`	省会城市
广东省	深圳市	`440300`	一线城市
浙江省	杭州市	`330100`	省会城市
江苏省	南京市	`320100`	省会城市
四川省	成都市	`510100`	省会城市

完整的行政区划码映射表请参考：附录：行政区划码映射表

2.1 写入流程简述​

数据准备：准备 JSONL 数据文件​

数据准备：通过 saastool 写入服务端​

数据准备：DS 中的数据存储​

脚本：编写 Lua 实现拉活与调权​

脚本：测试​

脚本：上线​

回收：效果验证​

2.2 数据底层​

2.2.1 一方数据​

2.2.1.1 数据空间​

2.2.1.2 数据空间内存储​

2.2.1.3 字段使用​

2.2.1.4 使用示例​

2.2.1.5 底层存储结构示意​

2.2.1.6 默认值​

2.2.2 二方数据​

2.2.2.1 获取安装态​

2.2.3 三方数据​

2.2.3.1 获取打分​

2.3 数据写入​

2.3.1 DID数据写入(DID区)​

2.3.1.1 检查数据区开通状态​

2.3.1.2 数据准备​

数据格式说明​

数据准备示例​

2.3.1.3 写入方法​

方法一：使用 saastool 命令行工具写入​

方法二：使用 API 接口写入​

方法三：使用 saastool HTTP daemon 模式​

方法四：使用 Task 任务批量写入（推荐大数据量）​

2.3.1.5 数据验证​

2.3.1.6 写入方法对比​

2.3.1.7 注意事项​

2.3.1.8 最佳实践​

2.3.2 手机号数据写入(WUID区)​

2.3.2.1 检查数据区开通状态​

2.3.2.2 数据准备​

数据格式说明​

数据准备示例​

2.3.2.3 写入方法​

方法一：使用 saastool 命令行工具写入（手机号哈希）​

方法二：使用 API 接口写入（手机号哈希）​

方法三：使用 Task 任务批量写入（推荐大数据量）​

2.3.2.4 注意事项​

2.3.2.5 写入方法对比​

2.3.2.6 最佳实践​

2.3.3 OpenID数据写入(WUID区)​

2.3.3.1 检查数据区开通状态​

2.3.3.2 数据准备​

数据格式说明​

数据准备示例​

2.3.3.3 写入方法​

方法一：使用 saastool 命令行工具写入（OpenID）​

方法二：使用 API 接口写入（OpenID）​

方法三：使用 saastool HTTP daemon 模式（OpenID）​

方法四：使用 Task 任务批量写入（推荐大数据量）​

2.3.3.4 注意事项​

2.3.3.5 写入方法对比​

2.3.3.6 最佳实践​

2.3.3.7 OpenID 与手机号对比​

2.3.4 门店数据写入(GEO区)​

2.3.4.1 检查数据区开通状态​

2.3.4.2 数据准备​

2.3.4.3 写入方式​

方法一：使用 saastool CLI 工具​

方法二：使用 saashttp 包（程序集成）​

方法三：使用 saastool HTTP daemon 模式​

方法四：使用 Task 任务批量写入（推荐大数据量）​

2.3.4.4 数据验证​

2.3.4.5 注意事项​

2.3.4.6 最佳实践​

2.3.4.7 GEO 区与其他数据区对比​

2.3.4.8 经纬度转换工具函数​

2.3.5 IP城市数据写入(GEOIP区)​

2.3.5.1 检查数据区开通状态​

2.3.5.2 数据准备​

2.3.5.3 写入方式​

方法一：使用 saastool CLI 工具​

方法二：使用 saashttp 包（程序集成）​

2.1 写入流程简述

数据准备：准备 JSONL 数据文件

数据准备：通过 saastool 写入服务端

数据准备：DS 中的数据存储

脚本：编写 Lua 实现拉活与调权

脚本：测试

脚本：上线

回收：效果验证

2.2 数据底层

2.2.1 一方数据

2.2.1.1 数据空间

2.2.1.2 数据空间内存储

2.2.1.3 字段使用

2.2.1.4 使用示例

2.2.1.5 底层存储结构示意

2.2.1.6 默认值

2.2.2 二方数据

2.2.2.1 获取安装态

2.2.3 三方数据

2.2.3.1 获取打分

2.3 数据写入

2.3.1 DID数据写入(DID区)

2.3.1.1 检查数据区开通状态

2.3.1.2 数据准备

数据格式说明

数据准备示例

2.3.1.3 写入方法

方法一：使用 saastool 命令行工具写入

方法二：使用 API 接口写入

方法三：使用 saastool HTTP daemon 模式

方法四：使用 Task 任务批量写入（推荐大数据量）

2.3.1.5 数据验证

2.3.1.6 写入方法对比

2.3.1.7 注意事项

2.3.1.8 最佳实践

2.3.2 手机号数据写入(WUID区)

2.3.2.1 检查数据区开通状态

2.3.2.2 数据准备

数据格式说明

数据准备示例

2.3.2.3 写入方法

方法一：使用 saastool 命令行工具写入（手机号哈希）

方法二：使用 API 接口写入（手机号哈希）

方法三：使用 Task 任务批量写入（推荐大数据量）

2.3.2.4 注意事项

2.3.2.5 写入方法对比

2.3.2.6 最佳实践

2.3.3 OpenID数据写入(WUID区)

2.3.3.1 检查数据区开通状态

2.3.3.2 数据准备

数据格式说明

数据准备示例

2.3.3.3 写入方法

方法一：使用 saastool 命令行工具写入（OpenID）

方法二：使用 API 接口写入（OpenID）

方法三：使用 saastool HTTP daemon 模式（OpenID）

方法四：使用 Task 任务批量写入（推荐大数据量）

2.3.3.4 注意事项

2.3.3.5 写入方法对比

2.3.3.6 最佳实践

2.3.3.7 OpenID 与手机号对比

2.3.4 门店数据写入(GEO区)

2.3.4.1 检查数据区开通状态

2.3.4.2 数据准备

2.3.4.3 写入方式

方法一：使用 saastool CLI 工具

方法二：使用 saashttp 包（程序集成）

方法三：使用 saastool HTTP daemon 模式

方法四：使用 Task 任务批量写入（推荐大数据量）

2.3.4.4 数据验证

2.3.4.5 注意事项

2.3.4.6 最佳实践

2.3.4.7 GEO 区与其他数据区对比

2.3.4.8 经纬度转换工具函数

2.3.5 IP城市数据写入(GEOIP区)

2.3.5.1 检查数据区开通状态

2.3.5.2 数据准备

2.3.5.3 写入方式

方法一：使用 saastool CLI 工具

方法二：使用 saashttp 包（程序集成）