I have a db on cloud, how to export data into rdf from cloud ?

Hi everyone, I read https://neo4j-aura.canny.io/aura-general/p/need-apoc-full-on-aura and other links but I don't get it how to find a solution for apoc.ttl. Do I have to implement it myself? If yes how? Can I ask you to enable this ONLY feature on my account? Sorry If this was explained elsewhere but I cannot find it. It is very important because I cannot go to production without it and I'm forced to find an alternative to Aura if I don't find a solution, which would totally be a lot of effort to then maintain. Thank you, Calogero

I keep gettin no write service avaliable on a premium tier. This is unnnaccaptable.

This is not working Commands.UnknownCommandError Unknown command ":play https://guides.neo4j.com/V5-intro-neo4j-exercises/index.html ". The :play command is not currently available in workspace. You can request it on our feature request page. Available commands are: :clear remove all frames from the stream :param manage parameters :history open history sidebar

Hi, Is there a way to export a subset of data from one Aura cluster and create a new cluster from it ? For e.g , If I have 100 mill nodes and 100 mill relationships , I am interested in a logical subset of may be 1 mill nodes and relationships to be exported and restored to another Aura cluster . Looking forward to hearing from you

The command :use says it not supported but it's in the list of supported commands in the error message

For the same reasons explained in this post https://graphaware.com/neo4j/2019/09/06/custom-fulltext-analyzer.html It would be great to define custom analyzers in Aurora

Hi, I've played around with neo4j Aura and it perfectly fulfils all the needs of my startup except for the lack of RBAC / granular security. I understand that this is part of the enterprise tier which is fine but I would like to know if there are any plans for free limited use for this feature or scaleable payment options (I.e max number of free roles or role based requests)? This would be very useful in terms of designing, testing and prototyping more complex systems. As a startup I can see huge value in this proposition at the point at which the company is generating profits, however at the moment there is no way for a small company to make use of this critical feature. My only option currently is to implement custom RBAC which can be both time consuming and may be less secure. This limitation as a whole makes neo4j less desirable as a technology.

Please enable the history command so that one can look into prev commands.

We moved to the paid instances of neo4j Ever since we did we keep getting these errors from the neo4j connector sink It would be ok if after this error it would just reconnect, but i's not... this error continues until we restart the connector. Please help with it, otherwise you force us to move to our own instances. connect | at org.neo4j.driver.internal.util.Futures.blockingGet( Futures.java:111 ) connect | at org.neo4j.driver.internal.InternalTransaction.run ( InternalTransaction.java:58 ) connect | at org.neo4j.driver.internal.AbstractQueryRunner.run ( AbstractQueryRunner.java:34 ) connect | at org.neo4j.driver.internal.AbstractQueryRunner.run ( AbstractQueryRunner.java:39 ) connect | at streams.kafka.connect.sink.Neo4jSinkService$write$1$1$1.invoke$lambda-0(Neo4jSinkService.kt:50) connect | at org.neo4j.driver.internal.InternalSession.lambda$transaction$4( InternalSession.java:137 ) connect | at org.neo4j.driver.internal.retry.ExponentialBackoffRetryLogic.retry( ExponentialBackoffRetryLogic.java:106 ) connect | at org.neo4j.driver.internal.InternalSession.transaction( InternalSession.java:134 ) connect | at org.neo4j.driver.internal.InternalSession.writeTransaction( InternalSession.java:113 ) connect | at streams.kafka.connect.sink.Neo4jSinkService$write$1$1$1.invoke(Neo4jSinkService.kt:49) connect | at streams.kafka.connect.sink.Neo4jSinkService$write$1$1$1.invoke(Neo4jSinkService.kt:46) connect | at streams.utils.CoroutineUtilsKt.retryForException(CoroutineUtils.kt:7) connect | at streams.utils.CoroutineUtilsKt.retryForException(CoroutineUtils.kt:12) connect | at streams.utils.CoroutineUtilsKt.retryForException(CoroutineUtils.kt:12) connect | at streams.utils.CoroutineUtilsKt.retryForException(CoroutineUtils.kt:12) connect | at streams.utils.CoroutineUtilsKt.retryForException(CoroutineUtils.kt:12) connect | at streams.utils.CoroutineUtilsKt.retryForException(CoroutineUtils.kt:12) connect | at streams.kafka.connect.sink.Neo4jSinkService$write$1$1.invokeSuspend(Neo4jSinkService.kt:46) connect | at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33) connect | at kotlinx.coroutines.DispatchedTask.run (DispatchedTask.kt:106) connect | at kotlinx.coroutines.EventLoopImplBase.processNextEvent(EventLoop.common.kt:284) connect | at kotlinx.coroutines.BlockingCoroutine.joinBlocking(Builders.kt:85) connect | at kotlinx.coroutines.BuildersKt__BuildersKt.runBlocking(Builders.kt:59) connect | at kotlinx.coroutines.BuildersKt.runBlocking(Unknown Source) connect | at kotlinx.coroutines.BuildersKt__BuildersKt.runBlocking$default(Builders.kt:38) connect | at kotlinx.coroutines.BuildersKt.runBlocking$default(Unknown Source) connect | at streams.kafka.connect.sink.Neo4jSinkService.write(Neo4jSinkService.kt:45) connect | at streams.service.StreamsSinkService.writeWithStrategy(StreamsSinkService.kt:32) connect | at streams.service.StreamsSinkService.writeForTopic(StreamsSinkService.kt:40) connect | at streams.kafka.connect.sink.Neo4jSinkService$writeDataAsync$1$jobs$1$1$1.invokeSuspend(Neo4jSinkService.kt:84) connect | at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33) connect | at kotlinx.coroutines.DispatchedTask.run (DispatchedTask.kt:106) connect | at kotlinx.coroutines.internal.LimitedDispatcher.run (LimitedDispatcher.kt:42) connect | at kotlinx.coroutines.scheduling.TaskImpl.run (Tasks.kt:95) connect | at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:570) connect | at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:750) connect | at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:677) connect | at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:664) connect | Suppressed: org.neo4j.driver.internal.util.ErrorUtil$InternalExceptionCause connect | at org.neo4j.driver.internal.util.ErrorUtil.newNeo4jError( ErrorUtil.java:76 ) connect | at org.neo4j.driver.internal.async.inbound.InboundMessageDispatcher.handleFailureMessage( InboundMessageDispatcher.java:107 ) connect | at org.neo4j.driver.internal.messaging.common.CommonMessageReader.unpackFailureMessage( CommonMessageReader.java:75 ) connect | at org.neo4j.driver.internal.messaging.common.CommonMessageReader.read ( CommonMessageReader.java:53 ) connect | at org.neo4j.driver.internal.async.inbound.InboundMessageHandler.channelRead0( InboundMessageHandler.java:81 ) connect | at org.neo4j.driver.internal.async.inbound.InboundMessageHandler.channelRead0( InboundMessageHandler.java:37 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .SimpleChannelInboundHandler.channelRead( SimpleChannelInboundHandler.java:99 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:379 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:365 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.fireChannelRead( AbstractChannelHandlerContext.java:357 ) connect | at org.neo4j.driver.internal.shaded.io .netty.handler.codec.ByteToMessageDecoder.fireChannelRead( ByteToMessageDecoder.java:327 ) connect | at org.neo4j.driver.internal.shaded.io .netty.handler.codec.ByteToMessageDecoder.channelRead( ByteToMessageDecoder.java:299 ) connect | at org.neo4j.driver.internal.async.inbound.MessageDecoder.channelRead( MessageDecoder.java:42 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:379 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:365 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.fireChannelRead( AbstractChannelHandlerContext.java:357 ) connect | at org.neo4j.driver.internal.shaded.io .netty.handler.codec.ByteToMessageDecoder.fireChannelRead( ByteToMessageDecoder.java:327 ) connect | at org.neo4j.driver.internal.shaded.io .netty.handler.codec.ByteToMessageDecoder.fireChannelRead( ByteToMessageDecoder.java:314 ) connect | at org.neo4j.driver.internal.shaded.io .netty.handler.codec.ByteToMessageDecoder.callDecode( ByteToMessageDecoder.java:435 ) connect | at org.neo4j.driver.internal.shaded.io .netty.handler.codec.ByteToMessageDecoder.channelRead( ByteToMessageDecoder.java:279 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:379 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:365 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.fireChannelRead( AbstractChannelHandlerContext.java:357 ) connect | at org.neo4j.driver.internal.shaded.io .netty.handler.ssl.SslHandler.unwrap( SslHandler.java:1373 ) connect | at org.neo4j.driver.internal.shaded.io .netty.handler.ssl.SslHandler.decodeJdkCompatible( SslHandler.java:1236 ) connect | at org.neo4j.driver.internal.shaded.io .netty.handler.ssl.SslHandler.decode( SslHandler.java:1285 ) connect | at org.neo4j.driver.internal.shaded.io .netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection( ByteToMessageDecoder.java:510 ) connect | at org.neo4j.driver.internal.shaded.io .netty.handler.codec.ByteToMessageDecoder.callDecode( ByteToMessageDecoder.java:449 ) connect | at org.neo4j.driver.internal.shaded.io .netty.handler.codec.ByteToMessageDecoder.channelRead( ByteToMessageDecoder.java:279 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:379 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:365 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.fireChannelRead( AbstractChannelHandlerContext.java:357 ) connect | at org.neo4j.driver.internal.shaded.io .netty.handler.timeout.IdleStateHandler.channelRead( IdleStateHandler.java:286 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:379 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:365 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.fireChannelRead( AbstractChannelHandlerContext.java:357 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .DefaultChannelPipeline$HeadContext.channelRead( DefaultChannelPipeline.java:1410 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:379 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .AbstractChannelHandlerContext.invokeChannelRead( AbstractChannelHandlerContext.java:365 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .DefaultChannelPipeline.fireChannelRead( DefaultChannelPipeline.java:919 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .nio.AbstractNioByteChannel$NioByteUnsafe.read( AbstractNioByteChannel.java:166 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .nio.NioEventLoop.processSelectedKey( NioEventLoop.java:722 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .nio.NioEventLoop.processSelectedKeysOptimized( NioEventLoop.java:658 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel .nio.NioEventLoop.processSelectedKeys( NioEventLoop.java:584 ) connect | at org.neo4j.driver.internal.shaded.io.netty.channel.nio.NioEventLoop.run ( NioEventLoop.java:496 ) connect | at org.neo4j.driver.internal.shaded.io .netty.util.concurrent.SingleThreadEventExecutor$4.run( SingleThreadEventExecutor.java:997 ) connect | at org.neo4j.driver.internal.shaded.io .netty.util.internal.ThreadExecutorMap$2.run( ThreadExecutorMap.java:74 ) connect | at org.neo4j.driver.internal.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run ( FastThreadLocalRunnable.java:30 ) connect | at java.base/ java.lang.Thread.run ( Thread.java:829 ) connect | [2023-05-24 07:15:37,195] ERROR ErrorData(originalTopic=sink.neo4j.hierarchy.v0, timestamp=1684910239112, partition=0, offset=1216743, exception=org.neo4j.driver.exceptions.ClientException: No write operations are allowed directly on this database. Writes must pass through the leader. The role of this server is: FOLLOWER, key=null, value={op=merge, rel_type=MEMBER, from={op=merge, ids={uuid=e94c6760-00d8-45e5-85a5-caabb915ace9}, labels=[employees]}, to={op=merge, ids={uuid=0326d36a-bef8-4fe4-a5d2-35d5557b75fc}, labels=[departments]}, , executingClass=class streams.kafka.connect.sink.Neo4jSinkTask) (streams.kafka.connect.sink.Neo4jSinkTask) connect | org.neo4j.driver.exceptions.ClientException: No write operations are allowed directly on this database. Writes must pass through the leader. The role of this server is: FOLLOWER