@crvouga/ mockingbird-service-kinensis (中文(简体) )

本地模拟器。 真正的API合同. 部分 嘲笑鸟。 。 。 .

Amazon Kinesis数据流的国有本地模拟器。 无害环境管理;节点22+或Bun 1.2+.

使用量

import { CreateStreamCommand, KinesisClient, PutRecordCommand } from "@aws-sdk/client-kinesis"
import { NodeHttpHandler } from "@smithy/node-http-handler"
import { createServer } from "@crvouga/mockingbird-service-kinesis/server"

// Test setup: the Kinesis client your application already uses, pointed at the emulator.
// The client defaults to HTTP/2 on Node; the emulator serves HTTP/1.1, so pass NodeHttpHandler.
const server = await createServer()
const kinesis = new KinesisClient({
  endpoint: server.url,
  region: "us-east-1",
  credentials: { accessKeyId: "fixture", secretAccessKey: "fixture" },
  requestHandler: new NodeHttpHandler(),
})

// Application code, unchanged.
await kinesis.send(new CreateStreamCommand({ StreamName: "orders", ShardCount: 1 }))
const { ShardId, SequenceNumber } = await kinesis.send(
  new PutRecordCommand({
    StreamName: "orders",
    PartitionKey: "order-1",
    Data: new TextEncoder().encode('{"id":"order-1"}'),
  }),
)
// ShardId === "shardId-000000000000"

await server.close()

国家住在SQLite收藏 并参与共享运行时间命名空间隔离, 重置,时间表,时钟,日记,度量衡和故障控制. 不需要 AWS 账户 .

已执行的AWS业务: CreateStream, (中文(简体) ), DeleteStream, (中文(简体) ), ListStreams, (中文(简体) ), DescribeStream, (中文(简体) ), DescribeStreamSummary, (中文(简体) ), PutRecord, (中文(简体) ), PutRecords, (中文(简体) ), GetShardIterator, (中文(简体) ), GetRecords, (中文(简体) ), ListShards, (中文(简体) ), UpdateShardCount, (中文(简体) ), AddTagsToStream, (中文(简体) ), RemoveTagsFromStream, (中文(简体) ), ListTagsForStream。 。 。 .

本列表以外的操作明显失败 。 这个软件包模拟了API状态,而不是AWS基础设施, 生产配额、计费、IAM执行或供应商控制台。 特定服务的疏漏和 甲骨文证据记录于 aWS 覆盖分类账。 。 。 .

运行 bun run parity 启用本地端盘 http://127.0.0.1:4566; 不可用预告失败运行 . 没有记录此整合的本地Stack 运行 。 等同指令是一个有边框的只读 SDK 信封探测器,而不是完全供应商等同的证据.

安装

bun add @crvouga/mockingbird-service-kinesis

API 密码

• KinesisAPI(options?): 低级 AWS 运输实例 fetch 财务报告和审定财务报表 reset。 。 。 .

• createRuntime(options?):在进程中获取 API 和共享状态控制 .

• createServer(options?) 从 /server 条目: HTTP 收听器 url, (中文(简体) ), runtime,以及 close()。 。 。 .

• document, (中文(简体) ), operationIds,以及 supportedOperationIds:生成运输合同元数据.