Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-7724

Mongodb Adhoc snapshot with filtering on objectID in additional conditions

    XMLWordPrintable

Details

    • Bug
    • Resolution: Not a Bug
    • Major
    • None
    • None
    • mongodb-connector
    • None
    • False
    • None
    • False
    • Important

    Description

      Bug report

       

      I am trying to create a signal for an adhoc snapshot for a mongodb collection, and I want the snapshot to be on specific ObjectID, (ex: only trigger a snapshot where _id=63062eb99219e220863f01b) but the log keeps saying:

      Action execute-snapshot failed. The signal SignalRecord ... may not have been processed.

      Here is the the signal syntax:

       

      use debezium db.debeziumSignal.insertOne({ "type": "execute-snapshot", "data": { "data-collections": ["db.collection"], "additional-conditions": [ { "data-collection": "db.collection", "filter": "{ \"id\" : \"{\"$oid\" : \"63062eb99219e220863f01b\"}\" }" } ], "type": "incremental" } });

       

      and what if I want to trigger a snapshot on multiple ObjectIDs, how can I give it a list?

      What Debezium connector do you use and what version?

      Mongodb Connector

      What is the connector configuration?

      NA

      What is the captured database version and mode of depoyment?

      with a specific cloud provider (OCI)

      What behaviour do you expect?

      A signal must be correctly interpreted and a snapshot is triggered

      What behaviour do you see?

      An error saying:

      Action execute-snapshot failed. The signal SignalRecord ... may not have been processed.

      Do you see the same behaviour using the latest relesead Debezium version?

      NA

      Do you have the connector logs, ideally from start till finish?

      Yes

      How to reproduce the issue using our tutorial deployment?

      choose a collection with _id, let's say the _id is=63062eb99219e220863f01b , create this debezium signal for it:

       

      use debezium db.debeziumSignal.insertOne({ "type": "execute-snapshot", "data": { "data-collections": ["db.collection"], "additional-conditions": [ { "data-collection": "db.collection", "filter": "{ \"id\" : \"{\"$oid\" : \"63062eb99219e220863f01b\"}\" }" } ], "type": "incremental" } });

      Feature request or enhancement

      explicitly provide a how to for this use case in the documentation

      Which use case/requirement will be addressed by the proposed feature?

      Adhoc Snapshots

      Implementation ideas (optional)

      NA

      Attachments

        Activity

          People

            Unassigned Unassigned
            raghada.alkhudhair@gmail.com Raghad Alkhudhair
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: