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)))
