如何调用数据集 API

curl -H "X-API-Key: ds_你的密钥" \
  "https://www.dataocean.zhixxing.cn/api/v1/data/商品标识/rows?page=1&size=10"

import requests

API_KEY = "ds_你的密钥"
# 商品标识：在商品详情页或「我的购买」中查看
PRODUCT_CODE = "商品标识"
BASE = f"https://www.dataocean.zhixxing.cn/api/v1/data/{PRODUCT_CODE}"

resp = requests.get(
    f"{BASE}/rows",
    headers={"X-API-Key": API_KEY},
    params={"page": 1, "size": 10},  # 页码、每页条数
    timeout=30,
)
resp.raise_for_status()
payload = resp.json()
rows = payload["rows"]  # 本页数据行
print("总行数=", payload["total"], "本页条数=", len(rows))

const apiKey = "ds_你的密钥";
// 商品标识：在商品详情页或「我的购买」中查看
const productCode = "商品标识";
const url = new URL(`https://www.dataocean.zhixxing.cn/api/v1/data/${productCode}/rows`);
url.searchParams.set("page", "1");  // 页码
url.searchParams.set("size", "10"); // 每页条数

const resp = await fetch(url, {
  headers: { "X-API-Key": apiKey },
});
if (!resp.ok) throw new Error(`HTTP ${resp.status}`);
const payload = await resp.json();
console.log("总行数=", payload.total, "本页条数=", payload.rows.length);

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;

// 商品标识：在商品详情页或「我的购买」中查看
String productCode = "商品标识";
var client = HttpClient.newHttpClient();
var request = HttpRequest.newBuilder()
    .uri(URI.create("https://www.dataocean.zhixxing.cn/api/v1/data/" + productCode + "/rows?page=1&size=10"))
    .header("X-API-Key", "ds_你的密钥")
    .GET()
    .build();
var response = client.send(request, HttpResponse.BodyHandlers.ofString());
System.out.println(response.statusCode());
System.out.println(response.body());

package main

import (
	"fmt"
	"io"
	"net/http"
)

func main() {
	// 商品标识：在商品详情页或「我的购买」中查看
	productCode := "商品标识"
	req, _ := http.NewRequest("GET",
		"https://www.dataocean.zhixxing.cn/api/v1/data/"+productCode+"/rows?page=1&size=10", nil)
	req.Header.Set("X-API-Key", "ds_你的密钥")
	resp, err := http.DefaultClient.Do(req)
	if err != nil {
		panic(err)
	}
	defer resp.Body.Close()
	body, _ := io.ReadAll(resp.Body)
	fmt.Println(resp.StatusCode, string(body))
}

using System.Net.Http;

// 商品标识：在商品详情页或「我的购买」中查看
var productCode = "商品标识";
var client = new HttpClient();
client.DefaultRequestHeaders.Add("X-API-Key", "ds_你的密钥");
var json = await client.GetStringAsync(
    $"https://www.dataocean.zhixxing.cn/api/v1/data/{productCode}/rows?page=1&size=10");
Console.WriteLine(json);

for row in payload["rows"]:
    # 按该商品的字段说明读取列，勿写死某一商品的列名
    print(row)
    # ... 你的业务逻辑

for (const row of payload.rows) {
  // 按该商品的字段说明读取列
  console.log(row);
  // ... 你的业务逻辑
}

// 使用 Jackson / Gson 等将正文解析后：
for (JsonNode row : root.get("rows")) {
    // 按字段说明读取列
    // ... 你的业务逻辑
}

type RowPayload struct {
	Rows []map[string]any `json:"rows"`
}
var payload RowPayload
json.Unmarshal(body, &payload)
for _, row := range payload.Rows {
	// 按字段说明读取列
	_ = row
}

using System.Text.Json;

using var doc = JsonDocument.Parse(json);
foreach (var row in doc.RootElement.GetProperty("rows").EnumerateArray())
{
    // 按字段说明读取列
    // ... 你的业务逻辑
}

import requests

def fetch_rows(api_key: str, product_code: str, page: int = 1, size: int = 10):
    r = requests.get(
        f"https://www.dataocean.zhixxing.cn/api/v1/data/{product_code}/rows",
        headers={"X-API-Key": api_key},
        params={"page": page, "size": size},
        timeout=30,
    )
    if r.status_code == 401:
        raise SystemExit("API 密钥无效或已撤销，请到「我的购买」重新申请")
    if r.status_code == 403:
        raise SystemExit("无购买权限，请先购买该数据集")
    if r.status_code == 400:
        raise SystemExit(f"参数错误: {r.json()}")
    if r.status_code == 429:
        raise SystemExit("请求过于频繁，请稍后重试")
    r.raise_for_status()
    return r.json()

data = fetch_rows("ds_你的密钥", "商品标识")
print(data["rows"][0])

async function fetchRows(apiKey, productCode, page = 1, size = 10) {
  const url = new URL(`https://www.dataocean.zhixxing.cn/api/v1/data/${productCode}/rows`);
  url.searchParams.set("page", String(page));
  url.searchParams.set("size", String(size));
  const resp = await fetch(url, { headers: { "X-API-Key": apiKey } });
  if (resp.status === 401) throw new Error("API 密钥无效或已撤销");
  if (resp.status === 403) throw new Error("无购买权限，请先购买该数据集");
  if (resp.status === 400) throw new Error(`参数错误: ${await resp.text()}`);
  if (resp.status === 429) throw new Error("请求过于频繁，请稍后重试");
  if (!resp.ok) throw new Error(`HTTP ${resp.status}`);
  return resp.json();
}

const data = await fetchRows("ds_你的密钥", "商品标识");
console.log(data.rows[0]);

var response = client.send(request, HttpResponse.BodyHandlers.ofString());
switch (response.statusCode()) {
    case 401 -> throw new IllegalStateException("API 密钥无效或已撤销");
    case 403 -> throw new IllegalStateException("无购买权限，请先购买该数据集");
    case 400 -> throw new IllegalArgumentException("参数错误: " + response.body());
    case 429 -> throw new IllegalStateException("请求过于频繁，请稍后重试");
    default -> {
        if (response.statusCode() >= 400) {
            throw new IllegalStateException("HTTP " + response.statusCode());
        }
    }
}
System.out.println(response.body());

resp, err := http.DefaultClient.Do(req)
if err != nil {
	panic(err)
}
defer resp.Body.Close()
body, _ := io.ReadAll(resp.Body)
switch resp.StatusCode {
case 401:
	panic("API 密钥无效或已撤销")
case 403:
	panic("无购买权限，请先购买该数据集")
case 400:
	panic(fmt.Sprintf("参数错误: %s", body))
case 429:
	panic("请求过于频繁，请稍后重试")
}
if resp.StatusCode >= 400 {
	panic(fmt.Sprintf("HTTP %d", resp.StatusCode))
}
fmt.Println(string(body))

var productCode = "商品标识";
using var resp = await client.GetAsync(
    $"https://www.dataocean.zhixxing.cn/api/v1/data/{productCode}/rows?page=1&size=10");
var body = await resp.Content.ReadAsStringAsync();
switch ((int)resp.StatusCode)
{
    case 401: throw new Exception("API 密钥无效或已撤销");
    case 403: throw new Exception("无购买权限，请先购买该数据集");
    case 400: throw new Exception($"参数错误: {body}");
    case 429: throw new Exception("请求过于频繁，请稍后重试");
}
resp.EnsureSuccessStatusCode();
Console.WriteLine(body);