> For clean Markdown of any page, append .md to the page URL. > For a complete documentation index, see https://docs.cessy.ai/llms.txt. > For AI client integration (Claude Code, Cursor, etc.), connect to the MCP server at https://docs.cessy.ai/_mcp/server. # Bulk import events POST https://cessy.ai/api/rest/tenant-id/app-id/events/import Content-Type: application/json Imports historical events directly into runtime event streams. This bypasses command business rules and is intended for migration, seed, and replay workflows. Reference: https://docs.cessy.ai/runtime-api-template/events/import-events ## Authentication - `Authorization` header (bearer token, required) — Runtime bearer accepted by the normal app-scoped pipeline: an API key or OAuth/JWT with the 'runtime' scope, or an app-scoped agent service token. Individual operations may require a narrower principal type. ## Request ### Query parameters - `workspaceId` (string, optional) — Optional Workspace runtime selector for preview or validation calls. If supplied with X-CES-Workspace-ID, both values must match. ### Headers - `X-CES-Workspace-ID` (string, optional) — Optional Workspace runtime selector header. If supplied with workspaceId, both values must match. ### Body (application/json) This endpoint expects an EventImportRequest. - `events` (list of EventImportRequestEventsItems, required) - `publishToEventBus` (boolean, optional, default: true) ## Response ### 200 Events imported - `success` (boolean, required) - `imported` (integer, required) - `streams` (integer, required) - `warnings` (list of string, optional) ## Errors ### 400 Bad Request Error Invalid import request - `error` (string, required) - `message` (string, optional) — Operator-safe failure text when the endpoint exposes a typed error. - `details` (any, optional) - `code` (string, optional) — Stable machine-readable failure category when available. - `executionId` (string, optional) — Protected execution-log lookup identifier when execution started. - `correlationId` (string, optional) — Identifier for related requests and diagnostics when available. - `effectState` (enum, optional) — Authoritative confirmation that the command effect is absent. - Allowed values: `rejected`, `rolled_back` ### 409 Conflict Error Concurrent stream version conflict - `error` (string, required) - `message` (string, optional) — Operator-safe failure text when the endpoint exposes a typed error. - `details` (any, optional) - `code` (string, optional) — Stable machine-readable failure category when available. - `executionId` (string, optional) — Protected execution-log lookup identifier when execution started. - `correlationId` (string, optional) — Identifier for related requests and diagnostics when available. - `effectState` (enum, optional) — Authoritative confirmation that the command effect is absent. - Allowed values: `rejected`, `rolled_back` ### 422 Unprocessable Entity Error Event schema validation failed - `success` (boolean, required) - `error` (string, required) - `validationErrors` (list of EventImportFailureValidationErrorsItems, optional) ## Types ### EventImportRequestEventsItems - `type` (string, required) - `data` (map from string to any, required) - `scopeKey` (string, required) - `metadata` (map from string to any, optional) ### EventImportFailureValidationErrorsItems - `index` (integer, optional) - `message` (string, optional) ## Examples **Request** ```json { "events": [ { "type": "OrderPlaced", "data": {}, "scopeKey": "order-7f3a2b1c-4e5d-4f6a-8b9c-0d1e2f3a4b5c" } ] } ``` **Response** ```json { "success": true, "imported": 42, "streams": 7, "warnings": [ "Event at index 3 has no metadata; imported with defaults." ] } ``` **SDK Code** ```python import requests url = "https://cessy.ai/api/rest/tenant-id/app-id/events/import" payload = { "events": [ { "type": "OrderPlaced", "data": {}, "scopeKey": "order-7f3a2b1c-4e5d-4f6a-8b9c-0d1e2f3a4b5c" } ] } headers = { "Authorization": "Bearer ", "Content-Type": "application/json" } response = requests.post(url, json=payload, headers=headers) print(response.json()) ``` ```javascript const url = 'https://cessy.ai/api/rest/tenant-id/app-id/events/import'; const options = { method: 'POST', headers: {Authorization: 'Bearer ', 'Content-Type': 'application/json'}, body: '{"events":[{"type":"OrderPlaced","data":{},"scopeKey":"order-7f3a2b1c-4e5d-4f6a-8b9c-0d1e2f3a4b5c"}]}' }; try { const response = await fetch(url, options); const data = await response.json(); console.log(data); } catch (error) { console.error(error); } ``` ```go package main import ( "fmt" "strings" "net/http" "io" ) func main() { url := "https://cessy.ai/api/rest/tenant-id/app-id/events/import" payload := strings.NewReader("{\n \"events\": [\n {\n \"type\": \"OrderPlaced\",\n \"data\": {},\n \"scopeKey\": \"order-7f3a2b1c-4e5d-4f6a-8b9c-0d1e2f3a4b5c\"\n }\n ]\n}") req, _ := http.NewRequest("POST", url, payload) req.Header.Add("Authorization", "Bearer ") req.Header.Add("Content-Type", "application/json") res, _ := http.DefaultClient.Do(req) defer res.Body.Close() body, _ := io.ReadAll(res.Body) fmt.Println(res) fmt.Println(string(body)) } ``` ```ruby require 'uri' require 'net/http' url = URI("https://cessy.ai/api/rest/tenant-id/app-id/events/import") http = Net::HTTP.new(url.host, url.port) http.use_ssl = true request = Net::HTTP::Post.new(url) request["Authorization"] = 'Bearer ' request["Content-Type"] = 'application/json' request.body = "{\n \"events\": [\n {\n \"type\": \"OrderPlaced\",\n \"data\": {},\n \"scopeKey\": \"order-7f3a2b1c-4e5d-4f6a-8b9c-0d1e2f3a4b5c\"\n }\n ]\n}" response = http.request(request) puts response.read_body ``` ```java import com.mashape.unirest.http.HttpResponse; import com.mashape.unirest.http.Unirest; HttpResponse response = Unirest.post("https://cessy.ai/api/rest/tenant-id/app-id/events/import") .header("Authorization", "Bearer ") .header("Content-Type", "application/json") .body("{\n \"events\": [\n {\n \"type\": \"OrderPlaced\",\n \"data\": {},\n \"scopeKey\": \"order-7f3a2b1c-4e5d-4f6a-8b9c-0d1e2f3a4b5c\"\n }\n ]\n}") .asString(); ``` ```php request('POST', 'https://cessy.ai/api/rest/tenant-id/app-id/events/import', [ 'body' => '{ "events": [ { "type": "OrderPlaced", "data": {}, "scopeKey": "order-7f3a2b1c-4e5d-4f6a-8b9c-0d1e2f3a4b5c" } ] }', 'headers' => [ 'Authorization' => 'Bearer ', 'Content-Type' => 'application/json', ], ]); echo $response->getBody(); ``` ```csharp using RestSharp; var client = new RestClient("https://cessy.ai/api/rest/tenant-id/app-id/events/import"); var request = new RestRequest(Method.POST); request.AddHeader("Authorization", "Bearer "); request.AddHeader("Content-Type", "application/json"); request.AddParameter("application/json", "{\n \"events\": [\n {\n \"type\": \"OrderPlaced\",\n \"data\": {},\n \"scopeKey\": \"order-7f3a2b1c-4e5d-4f6a-8b9c-0d1e2f3a4b5c\"\n }\n ]\n}", ParameterType.RequestBody); IRestResponse response = client.Execute(request); ``` ```swift import Foundation let headers = [ "Authorization": "Bearer ", "Content-Type": "application/json" ] let parameters = ["events": [ [ "type": "OrderPlaced", "data": [], "scopeKey": "order-7f3a2b1c-4e5d-4f6a-8b9c-0d1e2f3a4b5c" ] ]] as [String : Any] let postData = JSONSerialization.data(withJSONObject: parameters, options: []) let request = NSMutableURLRequest(url: NSURL(string: "https://cessy.ai/api/rest/tenant-id/app-id/events/import")! as URL, cachePolicy: .useProtocolCachePolicy, timeoutInterval: 10.0) request.httpMethod = "POST" request.allHTTPHeaderFields = headers request.httpBody = postData as Data let session = URLSession.shared let dataTask = session.dataTask(with: request as URLRequest, completionHandler: { (data, response, error) -> Void in if (error != nil) { print(error as Any) } else { let httpResponse = response as? HTTPURLResponse print(httpResponse) } }) dataTask.resume() ```