Publish and retrieve skills through API

import json
import os
from pathlib import Path

from atlanai import AtlanClient

client = AtlanClient(
    os.environ["ATLAN_GATEWAY_URL"],
    bearer_token=os.environ["ATLAN_TOKEN"],
    workspace="workspace_01example",
)

skill = client.skills.create(
    body=Path("./release-notes.zip").read_bytes(),
    metadata=json.dumps(
        {
            "name": "release-notes",
            "description": "Turn merged changes into release notes.",
            "workspace_id": "workspace_01example",
        }
    ),
)
print(skill.id)

import { readFile } from "node:fs/promises";
import { AtlanClient } from "@atlanai/sdk";

const client = new AtlanClient({
  gatewayOrigin: process.env.ATLAN_GATEWAY_URL!,
  bearerToken: process.env.ATLAN_TOKEN!,
  workspace: "workspace_01example",
});

const skill = await client.skills.create({
  metadata: JSON.stringify({
    name: "release-notes",
    description: "Turn merged changes into release notes.",
    workspace_id: "workspace_01example",
  }),
  body: new Blob([await readFile("./release-notes.zip")]),
});
console.log(skill.id);

import io
import zipfile

version = client.skills.versions.get_enriched("skill_01example", version_ordinal=1)

archive = client.skills.versions.get_bundle("skill_01example", version_ordinal=1)
print(zipfile.ZipFile(io.BytesIO(archive)).namelist())

# The current bundle rather than a pinned version.
current = client.skills.get_bundle("skill_01example")

const version = await client.skills.versions.getEnriched({
  skillId: "skill_01example",
  versionOrdinal: 1,
});

const archive = await client.skills.versions.getBundle({
  skillId: "skill_01example",
  versionOrdinal: 1,
});

const current = await client.skills.getBundle({ skillId: "skill_01example" });

import time

runs = client.skills.traces.list("skill_01example", limit=10)

now = int(time.time())
stats = client.skills.traces.query_stats(
    "skill_01example",
    {
        "request_type": "scalar",
        "queries": [{"name": "runs", "measure": "traces"}],
        "start_time_unix_seconds": now - 7 * 86_400,
        "end_time_unix_seconds": now,
    },
)
for result in stats.data.actual_instance.results:
    print(result.query_name, result.measure, result.value)

import { rawSkill } from "@atlanai/sdk";

const runs = await client.skills.traces.list({
  skillId: "skill_01example",
  limit: 10,
});

const now = Math.floor(Date.now() / 1000);
const stats = await client.skills.traces.queryStats("skill_01example", {
  requestType: rawSkill.GatewayTraceStatsRequestType.Scalar,
  queries: [{ name: "runs", measure: rawSkill.GatewayTraceStatsMeasure.Traces }],
  startTimeUnixSeconds: now - 7 * 86_400,
  endTimeUnixSeconds: now,
});
// stats.data is a union discriminated by requestType; scalar results carry `results`.
if ("results" in stats.data) {
  for (const result of stats.data.results) {
    console.log(result.queryName, result.measure, result.value);
  }
}