快速开始

// Node.js 22+. real-event.json comes from your billing outbox.
import { readFile } from 'node:fs/promises';
const event = JSON.parse(await readFile('real-event.json', 'utf8'));
const response = await fetch(
  process.env.OT_API_ROOT + '/t/' + process.env.OT_TENANT + '/ingest/events',
  {
    method: 'POST',
    headers: {
      Authorization: 'Bearer ' + process.env.OT_INGEST_TOKEN,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify([event]),
    redirect: 'error',
  },
);
const result = await response.json();
if (!response.ok || result.success !== true) {
  throw new Error(JSON.stringify(result));
}
console.log(result); // enqueued means accepted, not yet signed or sealed

# Python 3. Use a real event from your billing outbox.
import json, os, urllib.request

class NoRedirect(urllib.request.HTTPRedirectHandler):
    def redirect_request(self, *args, **kwargs):
        return None

with open("real-event.json", encoding="utf-8") as source:
    event = json.load(source)
url = os.environ["OT_API_ROOT"] + "/t/" + os.environ["OT_TENANT"] + "/ingest/events"
request = urllib.request.Request(url,
    data=json.dumps([event]).encode(),
    headers={"Authorization": "Bearer " + os.environ["OT_INGEST_TOKEN"],
             "Content-Type": "application/json"}, method="POST")
with urllib.request.build_opener(NoRedirect).open(request, timeout=30) as response:
    result = json.load(response)
if result.get("success") is not True:
    raise RuntimeError(result)
print(result)  # enqueued is not a verification result

# jq is required. real-event.json must contain one real event object.
jq -s '.' real-event.json > batch.json
curl --fail-with-body -sS \
  "$OT_API_ROOT/t/$OT_TENANT/ingest/events" \
  -H "Authorization: Bearer $OT_INGEST_TOKEN" \
  -H "Content-Type: application/json" \
  --data-binary @batch.json