LogDataSource
Defined in: js-api/src/dapi.ts:2266
Common functionality for handling collections of entities stored on the server. Works with Datagrok REST API, allows to get filtered and paginated lists of entities, Can be extended with specific methods. (i.e. UsersDataSource)
The fluent methods (filter, order, page, by, include, ...) are immutable: each returns a new source and leaves this one as it was, so a source can be kept in a variable and reused as a starting point.
Example
const projects = grok.dapi.projects.order('createdOn', true);
const recent = await projects.filter('createdOn > -1w').list({pageSize: 20});
const all = await projects.list(); // still unfiltered
Extends
Constructors
Constructor
new LogDataSource(
s):LogDataSource
Defined in: js-api/src/dapi.ts:2267
Parameters
| Parameter | Type |
|---|---|
s | any |
Returns
LogDataSource
Overrides
Properties
| Property | Type | Inherited from | Defined in |
|---|---|---|---|
clsName | string | HttpDataSource.clsName | js-api/src/dapi.ts:323 |
dart | any | HttpDataSource.dart | js-api/src/dapi.ts:322 |
Accessors
activity
Get Signature
get activity():
ActivityDataSource
Defined in: js-api/src/dapi.ts:2272
Activity API endpoint
Returns
Methods
allPackageVersions()
allPackageVersions():
this
Defined in: js-api/src/dapi.ts:404
A source without package version isolation: entities of all package versions, not only the current one.
Returns
this
Inherited from
HttpDataSource.allPackageVersions
by()
by(
i):this
Defined in: js-api/src/dapi.ts:409
A source that returns at most [i] entities per page. See also page.
Parameters
| Parameter | Type |
|---|---|
i | number |
Returns
this
Inherited from
count()
count():
Promise<number>
Defined in: js-api/src/dapi.ts:375
Counts entities that satisfy the filtering criteria (see filter). See examples: https://public.datagrok.ai/js/samples/dapi/projects-list Smart filter: https://datagrok.ai/help/datagrok/smart-search
Returns
Promise<number>
Inherited from
delete()
delete(
e):Promise<void>
Defined in: js-api/src/dapi.ts:399
Deletes an entity.
Parameters
| Parameter | Type |
|---|---|
e | Entity |
Returns
Promise<void>
Inherited from
filter()
filter(
w):this
Defined in: js-api/src/dapi.ts:429
A source filtered by [w]; replaces the filter of this source, if any. Also can be set with list method "options" parameter See example: https://public.datagrok.ai/js/samples/dapi/projects-list Smart filter: https://datagrok.ai/help/datagrok/concepts/objects#entity-search
Parameters
| Parameter | Type |
|---|---|
w | string |
Returns
this
Inherited from
find()
find(
id):Promise<LogEvent>
Defined in: js-api/src/dapi.ts:389
Returns an entity with the specified id. Throws an exception if an entity does not exist, or is not accessible in the current context. Sample: https://public.datagrok.ai/js/samples/data-access/save-and-load-df
Parameters
| Parameter | Type | Description |
|---|---|---|
id | string | GUID of the corresponding object |
Returns
Promise<LogEvent>
{Promise<object>} - entity.
Inherited from
first()
first():
Promise<LogEvent>
Defined in: js-api/src/dapi.ts:380
Returns the first entity that satisfies the filtering criteria (see filter).
Returns
Promise<LogEvent>
Inherited from
getArchiveEvents()
getArchiveEvents(
connection,key):Promise<DataFrame>
Defined in: js-api/src/dapi.ts:2319
Decodes one archived object into log events, same shape as getCloudLogEvents.
Parameters
| Parameter | Type |
|---|---|
connection | string |
key | string |
Returns
Promise<DataFrame>
getArchiveObjects()
getArchiveObjects(
connection,options?):Promise<DataFrame>
Defined in: js-api/src/dapi.ts:2314
Objects in the write-once log archive under prefix — key, modified, size.
Listing is the archive's only index; the keys carry the delivery date.
connection is an S3 data connection pointing at the archive bucket.
Parameters
| Parameter | Type |
|---|---|
connection | string |
options? | { limit?: number; prefix?: string; } |
options.limit? | number |
options.prefix? | string |
Returns
Promise<DataFrame>
getCloudLogEvents()
getCloudLogEvents(
group,start,end,options?):Promise<DataFrame>
Defined in: js-api/src/dapi.ts:2302
Events from a cloud log group — the hot, queryable tier (30 days).
filter is a CloudWatch filter pattern, not a regular expression: a bare
word matches a substring, ?a ?b is OR, -x excludes.
Parameters
| Parameter | Type |
|---|---|
group | string |
start | Dayjs |
end | Dayjs |
options? | { connection?: string; filter?: string; limit?: number; } |
options.connection? | string |
options.filter? | string |
options.limit? | number |
Returns
Promise<DataFrame>
Example
const df = await grok.dapi.log.getCloudLogEvents('/datagrok/public',
dayjs().subtract(1, 'hour'), dayjs(), {filter: 'error'});
getCloudLogGroups()
getCloudLogGroups(
options?):Promise<string[]>
Defined in: js-api/src/dapi.ts:2288
Names of the cloud log groups this instance can read.
Admins only. Without a connection the server uses its own AWS role.
Parameters
| Parameter | Type |
|---|---|
options? | { connection?: string; prefix?: string; } |
options.connection? | string |
options.prefix? | string |
Returns
Promise<string[]>
Example
const groups = await grok.dapi.log.getCloudLogGroups({prefix: '/datagrok/'});
include()
include(
include):this
Defined in: js-api/src/dapi.ts:439
A source that also loads the [include]d properties of every entity (adds to this source's includes).
Parameters
| Parameter | Type |
|---|---|
include | string |
Returns
this
Inherited from
list()
list(
options?):Promise<LogEvent[]>
Defined in: js-api/src/dapi.ts:359
Returns all entities that satisfy the filtering criteria (see filter). See examples: https://public.datagrok.ai/js/samples/dapi/projects-list Smart filter: https://datagrok.ai/help/datagrok/smart-search
Parameters
| Parameter | Type |
|---|---|
options | { filter?: string; order?: string; pageNumber?: number; pageSize?: number; } |
options.filter? | string |
options.order? | string |
options.pageNumber? | number |
options.pageSize? | number |
Returns
Promise<LogEvent[]>
Inherited from
nextPage()
nextPage():
this
Defined in: js-api/src/dapi.ts:421
A source for the page after this one (the first call gives page 1). Reassign to advance:
source = source.nextPage().
See examples: https://public.datagrok.ai/js/samples/dapi/projects-list
Returns
this
Inherited from
order()
order(
fieldName,desc?):this
Defined in: js-api/src/dapi.ts:434
A source ordered by [fieldName]; replaces the order of this source, if any.
Parameters
| Parameter | Type | Default value |
|---|---|---|
fieldName | string | undefined |
desc | boolean | false |
Returns
this
Inherited from
page()
page(
i):this
Defined in: js-api/src/dapi.ts:414
A source restricted to page [i]. See also nextPage.
Parameters
| Parameter | Type |
|---|---|
i | number |
Returns
this
Inherited from
save()
save(
e):Promise<LogEvent>
Defined in: js-api/src/dapi.ts:394
Saves an entity; the saved copy comes back with this source's includes loaded.
Parameters
| Parameter | Type |
|---|---|
e | Entity |
Returns
Promise<LogEvent>
Inherited from
where()
where(
options?):LogDataSource
Defined in: js-api/src/dapi.ts:2276
Parameters
| Parameter | Type |
|---|---|
options? | { end?: Dayjs; entityId?: string; favoritesOnly?: boolean; start?: Dayjs; } |
options.end? | Dayjs |
options.entityId? | string |
options.favoritesOnly? | boolean |
options.start? | Dayjs |
Returns
LogDataSource
with()
protectedwith(patch):this
Defined in: js-api/src/dapi.ts:334
A copy of this source whose query has [patch] applied. The Dart handle is shared; its state is rebuilt from the query right before every request, so the copies never observe each other.
Parameters
| Parameter | Type |
|---|---|
patch | Partial<DataSourceQuery> |
Returns
this