SDK reference

# ctx.app_db.get_entity(entity_name, entity_id)
product = ctx.app_db.get_entity('product', request['id'])

// await ctx.app_db.getEntity(entityName, entityId)
const product = await ctx.app_db.getEntity('product', request.id);

# ctx.app_db.list_entities(entity_name, filters=None, limit=None, next_token=None, sort_by=None, sort_dir=None)
page = ctx.app_db.list_entities('product', filters=[{'field':'price','op':'lt','value':20}], limit=10, sort_by='updated_at', sort_dir='desc')

// await ctx.app_db.listEntities(entityName, filters?, limit?, nextToken?, sortBy?, sortDir?)
const page = await ctx.app_db.listEntities('product', [{field:'price',op:'lt',value:20}], 10, undefined, 'updated_at', 'desc');

# ctx.app_db.create_entity(entity_name, fields)
new_row = ctx.app_db.create_entity('product', {'title': 'Mug', 'price': 12})

// await ctx.app_db.createEntity(entityName, fields)
const newRow = await ctx.app_db.createEntity('product', { title: 'Mug', price: 12 });

# ctx.app_db.update_entity(entity_name, entity_id, fields)
ctx.app_db.update_entity('product', request['id'], {'price': 10})

// await ctx.app_db.updateEntity(entityName, entityId, fields)
await ctx.app_db.updateEntity('product', request.id, { price: 10 });

# ctx.app_db.delete_entity(entity_name, entity_id)
ctx.app_db.delete_entity('product', request['id'])

// await ctx.app_db.deleteEntity(entityName, entityId)
await ctx.app_db.deleteEntity('product', request.id);

# ctx.app_db.batch_create_entities(entity_name, items)
ctx.app_db.batch_create_entities('product', [{'title':'A'},{'title':'B'}])

// await ctx.app_db.batchCreateEntities(entityName, items)
await ctx.app_db.batchCreateEntities('product', [{title:'A'},{title:'B'}]);

# ctx.content_s3.get_object(key)
pdf_bytes = ctx.content_s3.get_object('invoices/inv-1.pdf')

// await ctx.content_s3.getObject(key)
const pdfBytes = await ctx.content_s3.getObject('invoices/inv-1.pdf');

# ctx.content_s3.put_object(key, body, content_type=None)
ctx.content_s3.put_object('receipts/r-1.txt', 'Thanks!', 'text/plain')

// await ctx.content_s3.putObject(key, body, contentType?)
await ctx.content_s3.putObject('receipts/r-1.txt', 'Thanks!', 'text/plain');

# ctx.http.get(url)
resp = ctx.http.get('https://api.example.com/rates')

// await ctx.http.get(url)
const resp = await ctx.http.get('https://api.example.com/rates');

# ctx.http.post(url, body=None, headers=None)
ctx.http.post('https://api.example.com/webhook', {'event': 'done'})

// await ctx.http.post(url, body?, headers?)
await ctx.http.post('https://api.example.com/webhook', { event: 'done' });

# ctx.eventbridge.publish(event_type, detail=None)
ctx.eventbridge.publish('order_ready_for_pickup', {'order_id': request['id']})

// await ctx.eventbridge.publish(eventType, detail?)
await ctx.eventbridge.publish('order_ready_for_pickup', { orderId: request.id });

# ctx.queue.reinvoke(payload, delay_seconds=None)
ctx.queue.reinvoke({'step': 2}, delay_seconds=30)

// await ctx.queue.reinvoke(payload, delaySeconds?)
await ctx.queue.reinvoke({ step: 2 }, 30);

# ctx.ses.send(to, subject, body, cc=None, bcc=None, format=None)
ctx.ses.send(['customer@example.com'], 'Your order shipped', 'Thanks for your order!')

// await ctx.ses.send(to, subject, body, options?)
await ctx.ses.send(['customer@example.com'], 'Your order shipped', 'Thanks for your order!');

# ctx.connector.invoke(connector_id, action_id, fields=None, entity_ref=None)
out = ctx.connector.invoke('paypal', 'checkout_cart', {'line_items': items, 'currency_code': 'USD', 'total': '21.48'}, entity_ref=order['id'])
url = out['result']['checkout_url']

// await ctx.connector.invoke(connectorId, actionId, fields?, entityRef?)
const out = await ctx.connector.invoke('paypal', 'checkout_cart', { line_items: items, currency_code: 'USD', total: '21.48' }, order.id);
const url = out.result.checkout_url;

# ctx.org_code
org = ctx.org_code

// ctx.orgCode
const org = ctx.orgCode;

# ctx.tenant_code
tenant = ctx.tenant_code

// ctx.tenantCode
const tenant = ctx.tenantCode;

# ctx.user
who = ctx.user.sub if ctx.user else None
email = ctx.user.email if ctx.user else None

// ctx.user
const who = ctx.user?.sub;
const email = ctx.user?.email;

# ctx.config
api_key = ctx.config.get('api_key')

// ctx.config
const apiKey = ctx.config.apiKey;

# ctx.params.settings / ctx.params.secrets
region = ctx.params.settings.get('region')
api_key = ctx.params.secrets['API_KEY']

// ctx.params.settings / ctx.params.secrets
const region = ctx.params.settings.region;
const apiKey = ctx.params.secrets.API_KEY;

# ctx.log(*args)
ctx.log('processing order', request['id'])

// ctx.log(...args)
ctx.log('processing order', request.id);