Hello there !
I've tried for hours to make a simple query with Scanamo, but I didn't succeed.
I would live to make a query with a constraint on a column : the value must be in a set.
I tried something like : usageIndex.query('PhotoId -> ids.map(_.value)) but that returns no result at all.
There's an implicit method creating a ConditionExpression[(AttributeName, Set[V])], so I'm running this way...
If you have time to help me, I really appreciate ! Thank you
I've tried for hours to make a simple query with Scanamo, but I didn't succeed.
I would live to make a query with a constraint on a column : the value must be in a set.
I tried something like : usageIndex.query('PhotoId -> ids.map(_.value)) but that returns no result at all.
There's an implicit method creating a ConditionExpression[(AttributeName, Set[V])], so I'm running this way...
If you have time to help me, I really appreciate ! Thank you
My request works if I write something like usageIndex.query('PhotoId -> "123"), but can't work with a set of values. I tried to build an Or Condition from my ids list, but I failed also
hmm, yeah that won’t work, the partition key must be a scalar. check out https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/HowItWorks.CoreComponents.html#HowItWorks.CoreComponents.PrimaryKey
I have a ridiculously basic question about Scanamo - I'm trying to use ScanamoAlpakka in order to get a akka.stream.scaladsl.Source, and the Scaladoc says this is possible, depending on the "kind of execution used" - I can't find any examples in the docs, and am struggling a bit. Has anyone done this, and if so, where can I find the docs on how to do it?
i have
import org.scanamo.semiauto._
import org.scanamo.syntax._
i think it's because my type has
Instant in it
eh, removed
Instant and it still doesn't like it
like if i have
sealed trait Thing
case class Foo(a: Int, b: String) extends Thing
case class Bar(a: Long, b: String, c: Int) extends Thing
val thingTable: Table[Thing] = Table[Thing]("thing_table")(deriveDynamoFormat[Thing])genericProduct | genericCoProduct
both are in scope
if I provide one explicitly I see
could not find implicit value for parameter gen: shapeless.LabelledGeneric.Aux[T,R]
here is a reproduction
Hello. Is there an example of incrementing/decrementing? I found scanamo/scanamo#114 that claims one could use
add in an update, but as far as I can tell, add adds a field, rather than incrementing its value. Am I missing something?
Hey all, I've got a table and a GSI (Global secondary index) which has a primary key of org (S) and sort key of a timestamp (N).
I'm trying to query without success on this secondary index.
I've also tried to use
Can you please help here? How do I filter my primary key and also using range query (such as between ) on my sort key in a GSI, note that I can't use filter since I'm using the sort key and dynamo won't allow that
I'm trying to query without success on this secondary index.
val query = secondaryIndex .query('org -> org.name and 'timestamp >= startTimeMs) which is fine butval query = secondaryIndex .query('org -> org.name and 'timestamp >= startTimeMs and 'timestamp <= endTimeMs) isn't compile.I've also tried to use
between but that neither succeeded.Can you please help here? How do I filter my primary key and also using range query (such as between ) on my sort key in a GSI, note that I can't use filter since I'm using the sort key and dynamo won't allow that
Is this group still active? I'm trying to derive DynamoFormat for io.estatico.newtype.
import io.estatico.newtype.ops._
implicit def coercibleDecoder[A:Coercible[B, *],B]: DynamoFormat[A] =
DynamoFormat.coercedXmap[A, B, IllegalArgumentException](_.coerce[A])(
_.repr.asInstanceOf[B]
)But I get
Error:(107, 78) could not find implicit value for evidence parameter of type org.scanamo.DynamoFormat[B]
DynamoFormat.coercedXmap[A, B, IllegalArgumentException](_.coerce[A])(Can anyone help?
@rabzu Looks like the group moved to https://gitter.im/scanamo/scanamo
You need DynamoFormat[B] in context to derive DynamoFormat[A] in this case
You need DynamoFormat[B] in context to derive DynamoFormat[A] in this case
Hi there, I hope it is the right place to ask questions about scanamo. I have a table with global secondary index with projection type
INCLUDE , so I have only couple of fields in the index in comparison to the table itself. During query I have InvalidPropertiesError . Is that a way to query GSI with projection in scanamo?
Hello, we're intending to use Dynamo to track basic usage statistics for some events. In our current table layout, we'd have a composite key and then a dynamic set of attributes with number values. e.g.
PK | sortKey | dynamicAttr1 | dynamicAttr2 | ..
----
1 | 2020-05-28 | 7 | 4 | ...
1 | 2020-05-29 | 12 | null | ...
2 | 2020-05-29 | null | 3 | ...
...The above is easily done with the add UpdateExpression and generating a Symbol. However, is there an easy way to deserialize the items back out when doing a GET / Scan? Ideally, into something like a Map[String, Long] or Seq[(String, Long)]
Is there an easy way to get a non materialized list for a query?
Something like
def iterateAll(query: Query[_]): ScanamoOps[Iterator[Either[DynamoReadError, V]]]I would not mind creating my own wrapper using .from and .limit as a paging mechanism, but the lastEvaluatedKey is not accessible and therefore I cannot use it in the next .from
Use case is a query going through millions of items that I do not want to bring in memory but would like to execute a side effect on
val toLazyList: Id ~> LazyList = new (Id ~> LazyList) {
def apply[A](fa: Id[A]): LazyList[A] = LazyList(fa)
}
val op = si.queryPaginatedM[LazyList](query, pageSize = 10000)
scanamo.execT(toLazyList)(op).flatten // LazyList[Either[DynamoReadError, V]]
Hey all, I have been trying to create a table with more than one GSI but wouldn't. I am able to create a table with a single GSI and query the same though. Couldn't find examples for more than one GSI too. Can someone please point me to some resource/functions on how to do it.Thanks!!
Hi, am I right in assuming that this code still suffers from the same problem depicted here https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/WorkingWithItems.html#WorkingWithItems.ConditionalUpdate
Two independent services with this code might both read an item and update the table with their version instead of sequentially doing this operation?
Creating a lost transaction?
Two independent services with this code might both read an item and update the table with their version instead of sequentially doing this operation?
Creating a lost transaction?
scanamoClient.exec(table.`given`("amountLeft" >= amountToTake).update(e, add("amountLeft" -> -amountToTake)))
hi all :wave: - new here and hoping to get a maintainer's eyes on this PR scanamo/scanamo#1324
3 replies
hey! I'm trying to figure out how to delete an item from dynamo db using a composite key.
it appears that doing this:.delete(EntityIdKey === entityId and(RangeKey === rangeKey.value))
(the composite key is comprised from the hash of EntityId, and range key of RangeKey)
results to Query key condition not supported responses while testing
I've been looking at documentation but can't really see anything around my use case?
hrmm... seems like i can't read or update either, I guess my configuration is wrong for the composite key:
val keys = Seq(
KeySchemaElement
.builder()
.attributeName(EntityIdKey)
.keyType(KeyType.HASH).build(),
KeySchemaElement
.builder()
.attributeName(RangeKey)
.keyType(KeyType.RANGE).build(),
)
val attributes = Seq(
AttributeDefinition
.builder()
.attributeName(EntityIdKey)
.attributeType(ScalarAttributeType.N)
.build(),
AttributeDefinition
.builder()
.attributeName(RangeKey)
.attributeType(ScalarAttributeType.N)
.build(),
)
val cfg = DynamoDbSetup.DynamoTableConfig(
tableName = tableConfig.tableName,
capacityConfig = DynamoDbSetup.OnDemand,
ttlConfig = None,
)
DynamoDbSetup.createTable(dynamoDbClient, cfg, keys, attributes)What am I doing wrong?