Does Azure Cosmos Gremlin Supports Transaction Management?

Question

Does Azure Cosmos Gremlin Supports Transaction Management?

Vamshi, Merugu 20

Im trying to achieve transaction management in cosmos gremlin. Like i should be able to create some nodes and edges in a single transaction, if one of the operation fails the entire transaction should be discarded, like in sql terms commit and rollback. Would i be able to achieve that ?

I tried using DriverRemoteConnection from gremlin driver, which seems to have commit and rollback, but i cant run any queries using connection.submit(), because this strictly uses Bytecode traversal, which is an unsupported feature of cosmos gremlin https://learn.microsoft.com/en-us/azure/cosmos-db/gremlin/support#unsupported-features.

im using node gremlin package

export const connection : driver.DriverRemoteConnection = new driver.DriverRemoteConnection(
  endpoint,
  {
    authenticator,
    traversalsource: 'g',
    rejectUnauthorized: true,
    mimeType: 'application/vnd.gremlin-v2.0+json',
  }
);

const query = "g.addV('TEST').property('id', 'test').property('partitionKey', 'test').property('name', 'test')";
await connection.open();
const res1 = await connection.submit(query) // fails here saying 'Argument of type 'string' is not assignable to parameter of type 'Bytecode''
await connection.commit();

So, i changed my approach little bit using process.traversal from gremlin package

const tx = process.traversal().withRemote(connection).tx();
  const g = tx.begin();
  const res1 = await g.addV('VMER').property('id', '2').property('partitionKey', '2').iterate();
  Logger.info('Query executed successfully', res1);
  await tx.commit();

this fails with below error

Stack: ResponseError: Server error: 
[2024-10-29T10:26:46.172Z] 
[2024-10-29T10:26:46.172Z] ActivityId : 8cfb0fcf-7ae1-42c5-9759-d1aa7b23f984
[2024-10-29T10:26:46.172Z] ExceptionType : GraphMalformedException
[2024-10-29T10:26:46.172Z] ExceptionMessage : 
[2024-10-29T10:26:46.172Z]      Gremlin Malformed Request: Unsupported request operation: 'bytecode'.
[2024-10-29T10:26:46.173Z]      GremlinRequestId : e1dda306-ac20-454f-a9c0-7c075c75923b
[2024-10-29T10:26:46.173Z]      Context : global
[2024-10-29T10:26:46.173Z]      GraphInterOpStatusCode : MalformedRequest
[2024-10-29T10:26:46.173Z]      HResult : 0x80131500

Any suggestions?

Mahesh Kurva 10,515 Reputation points Microsoft External Staff Moderator

2024-10-29T13:06:53.16+00:00
Hi @Vamshi, Merugu,

Welcome to the Microsoft Q&A and thank you for posting your questions here.

Im trying to achieve transaction management in cosmos gremlin. Like i should be able to create some nodes and edges in a single transaction, if one of the operation fails the entire transaction should be discarded, like in sql terms commit and rollback. Would i be able to achieve that ?

Yes, you can achieve transaction management in Cosmos Gremlin. Cosmos DB supports full ACID compliant transactions with snapshot isolation for operations within the same logical partition key.

For more information, please refer the document: https://learn.microsoft.com/en-us/azure/cosmos-db/nosql/transactional-batch?tabs=dotnet

https://learn.microsoft.com/en-us/azure/cosmos-db/nosql/stored-procedures-triggers-udfs

The error message suggests that the query you are trying to execute is malformed. Please make sure that the query is correct and follows the syntax of Gremlin.

The query seems to be missing the label property for the vertex.

Here is an example:

const tx = process.traversal().withRemote(connection).tx(); const g = tx.begin(); const res1 = await g.addV('VMER').property('id', '2').property('partitionKey', '2').property('name', 'VMER').iterate(); Logger.info('Query executed successfully', res1); await tx.commit();

I hope this information helps. Please do let us know if you have any further queries.
Vamshi, Merugu 20 Reputation points

2024-10-29T13:35:06.74+00:00
Hi @Mahesh Kurva ,
i tried your example and still its the same issue. looks like the error is more of a compatibility issue, it says says that the cosmos gremlins does not support bytecode traversals

Unsupported request operation: 'bytecode'.

and i have gone through the documentation which you have shared, and i see that applies to NoSQL db.

does it still applies to Gremlin API ?

Answer accepted by question author

0 additional answers

Your answer

Mahesh Kurva 10,515 Reputation points Microsoft External Staff Moderator

2024-10-29T13:06:53.16+00:00

Hi @Vamshi, Merugu,

Welcome to the Microsoft Q&A and thank you for posting your questions here.

Im trying to achieve transaction management in cosmos gremlin. Like i should be able to create some nodes and edges in a single transaction, if one of the operation fails the entire transaction should be discarded, like in sql terms commit and rollback. Would i be able to achieve that ?

Yes, you can achieve transaction management in Cosmos Gremlin. Cosmos DB supports full ACID compliant transactions with snapshot isolation for operations within the same logical partition key.

For more information, please refer the document: https://learn.microsoft.com/en-us/azure/cosmos-db/nosql/transactional-batch?tabs=dotnet

https://learn.microsoft.com/en-us/azure/cosmos-db/nosql/stored-procedures-triggers-udfs

The error message suggests that the query you are trying to execute is malformed. Please make sure that the query is correct and follows the syntax of Gremlin.

The query seems to be missing the label property for the vertex.

Here is an example:

const tx = process.traversal().withRemote(connection).tx(); const g = tx.begin(); const res1 = await g.addV('VMER').property('id', '2').property('partitionKey', '2').property('name', 'VMER').iterate(); Logger.info('Query executed successfully', res1); await tx.commit();

I hope this information helps. Please do let us know if you have any further queries.
Vamshi, Merugu 20 Reputation points

2024-10-29T13:35:06.74+00:00

Hi @Mahesh Kurva ,
i tried your example and still its the same issue. looks like the error is more of a compatibility issue, it says says that the cosmos gremlins does not support bytecode traversals

Unsupported request operation: 'bytecode'.

and i have gone through the documentation which you have shared, and i see that applies to NoSQL db.

does it still applies to Gremlin API ?

Answer 1

Hi Vamshi, Merugu, Thank you for reaching out.

You are correct, the error you’re encountering is indeed due to a compatibility issue. Azure Cosmos DB for Gremlin does not support bytecode traversals. This limitation means that you cannot use the DriverRemoteConnection with bytecode traversal in Cosmos DB for Gremlin.

Please see the unsupported features.

Cosmos DB for Gremlin does not support transactions in the traditional sense, you won’t be able to use commit and rollback as you would in SQL databases.

The doc https://learn.microsoft.com/en-us/azure/cosmos-db/nosql/database-transactions-optimistic-concurrency you pointed out is only for nosql API.

Please file feedback at https://aka.ms/sqlfeedback (or add your vote to an existing feedback item if one already exists). A highly voted customer feedback item helps the product team prioritize the investment into the requested feature.

If you have any more questions or need further assistance, feel free to ask!

Regards,

Oury

Oury Ba-MSFT 21,126 Reputation points Microsoft Employee Moderator

2024-10-30T22:47:43.6533333+00:00

Hi Vamshi, Merugu,

We haven't heard back from yet. Please don't forget to mark as "accept answer" if the reply helped you clarify your ask. Otherwise, please do comment below if you have additional queries.

Regards,

Oury

Share via

Does Azure Cosmos Gremlin Supports Transaction Management?

0 additional answers

Your answer