- Retry for up to 24 hours if the exception is not
DuplicateKeyException
.
- Latest
mongochangestream
- Fix for downstreamprocessRecords
mutation.
- Fix to
process
eventfailed
property. - Latest
mongochangestream
- AddlastFlush
tostats
event.
- Latest
mongochangestream
- Fix pseudo ChangeStreamInsertDocument record.
- Deprecated
immutable
option forprocessChangeStream
in favor ofautoOptimizeInserts
option that works well in an insert-only or insert-heavy scenario. If you only wantinsert
events, you must pass{operationTypes: ['insert']}
. - Only return
_id
s forfailedDocs
andfailedDoc
in emitted events. - Bumped dependencies.
- Breaking Change: When there are multiple
overrides
that match the same path (e.g.*
andfoo.*
both match the pathfoo.bar
), they will now be applied in sequence, where the output of each override is passed as input to the next. - Added a
mapSchema
option as an "escape hatch" to allow preprocessing each node in the input object (usingmap
fromobj-walker
) before converting it to a Crate schema.
- Breaking Change: Default to dynamic object policy in
convertSchema
. See docs onstrictMode
option. - Added
failedRecords
toprocess
event andfailedRecord
toerror
for changestream events where applicable. - Added
options.mapper
toinitSync
.
- Bump packages, including latest
prom-utils
which allows for throttling of items/sec and bytes/sec.
- Latest
mongochangestream
- Latest
mongochangestream
- Fixed omit bugs. - Bumped peer dependencies for
ioredis
andmongodb
.
- Latest
mongochangestream
- Latest
mongochangestream
- Fix issue where omitting nested paths failed to remove the field fromupdateDescription.updatedFields
do to dotted field name.
- Added
operationCounts
to theprocess
event.
- Removed
options.mapper
in favor ofoptions.rename
which takes an object of dotted path to renamed dotted path. Therename
option is available for syncing and converting a schema to a table.
- Latest
mongochangestream
- Change stream optionoperationTypes
(insert
,update
,delete
, ...).
- Use bulk insert for immutable collections.
- Latest
mongochangestream
- supports batching for change stream events.mongo2crate
does not support this functionality, however.
- Latest
mongochangestream
- More robust error code handling formissingOplogEntry
.
- Latest
mongochangestream
- Don't emit thecursorError
event when stopping.
- Latest
mongochangestream
- FSM bug fix.
- Latest
mongochangestream
- Drop health check code in favor ofcursorError
event.
- Latest
mongochangestream
- extend event types.
- Latest
mongochangestream
-runInitialScan
pipeline.
- Optionally pass
mapper
for an override.
- Glob expressions supported for overrides
path
. - Pass any key/value pair in
Override
object.
- Latest
mongochangestream
- Handle master failover scenario properly for initial scan.
- Latest
mongochangestream
- LongermaxSyncDelay
default.
- Emit initial scan errors.
- Export
detectResync
.
- Latest
mongochangestream
- More robust cursor consumption.
- Added
flags
tooverrides
, including:notNull
,indexOff
, andcolumnStoreOff
.
- Latest
mongochangestream
- Bug fix.
- Latest
mongochangestream
- generic emitter. - Use emitter from
mongochangestream
which now emits two events on its own.
- Latest
mongochangestream
- bug fix.
- Latest
mongochangestream
- health checks.
- Add support for generating
CREATE TABLE IF NOT EXISTS (...fields) WITH (column_policy = 'dynamic')
when json schema hasadditionalProperties
set to true at the root
- Fixed an issue when updating a nested field like
foo.bar
orfoo.0.bar
.
- Forgot to bump
prom-utils
in this repo.
- Latest
mongochangestream
-batchBytes
option.
- Return
emitter
with events:process
anderror
. - Stats are no longer logged.
- Use
BIGINT
column type fornumber
when creating table schema.
- Removed
clearCompletedOn
. - Latest
mongochangestream
-JSONSchema
type.
- Latest
mongochangestream
- Option to strip metadata from a JSON schema fordetectSchemaChange
.
- Latest
mongochangestream
- Ensure that you can callstart
after callingstop
.
- Expose
schemaName
,tableName
,qualifiedName
.
- Schema can be set instead of defaulting to
doc
.
- Option to set
tableName
. - Handle
replace
event. - Latest
mongochangestream
.
- Latest
mongochangestream
with bug fix.
- Latest
mongochangestream
.
- Latest
mongochangestream
.
- Pass along
reset
and othermongochangestream
fns.
- Latest
mongochangestream
. detectSchemaChange
.
- Force path to be a string to conform to the change stream omit option.
- Changed
convertSchema
to acceptomit
andoverrides
.overrides
allow you to override the bsonType of any path.
- Added
getCollectionSchema
. - Added
createTableFromSchema
.
- Second parameter should be optional for
crate.query
.
- Added peer dependencies.
- Latest
mongochangestream
.
- Latest
mongochangestream
.
- Better defaults for
initSync
. - Better parameters for
crate
.
- Change argument order for
initSync
.
- Latest
mongochangestream
. - Omit fields via
initSync
which uses the pipeline for change stream events. - Changed
initSync
options. - Added
pipeline
argument toprocessChangeStream
.
- Initial release.