Estoy muy contento de informar que Couchbase ahora tiene un SDK Scala soportado, lo que le permite obtener y recuperar documentos, ejecutar consultas N1QL, realizar an\u00e1lisis y b\u00fasquedas de texto completo - todo con Scala nativo.<\/p>\n
En este blog voy a tocar las caracter\u00edsticas clave y los principios de dise\u00f1o del SDK de Scala. O si quieres ponerte en marcha de inmediato, entonces echa un vistazo a la gu\u00eda de iniciaci\u00f3n aqu\u00ed<\/a>. El SDK de Scala puede descargarse ahora mismo, en forma de versi\u00f3n alfa previa.<\/p>\n El SDK de Scala utiliza el mismo n\u00facleo interno estable y de alto rendimiento que el nuevo SDK de Java 3.x, por lo que, aunque es nuevo, puede estar seguro de que estar\u00e1 listo para la producci\u00f3n cuando llegue GA.<\/p>\n El SDK de Scala presenta una interfaz funcional, con la mayor\u00eda de las operaciones devolviendo un Try de Scala. Esto puede ser un \u00c9xito y contener el valor esperado, o un Fallo conteniendo un Throwable. Aunque al principio esto parece un poco verboso, y requiere cierta disciplina de programaci\u00f3n para manejar siempre los errores, esta forma de manejo de errores se convierte r\u00e1pidamente en una segunda naturaleza y le permite desarrollar con la seguridad de que una excepci\u00f3n aleatoria no va a ser lanzada desde el SDK.<\/p>\n Aqu\u00ed tienes una sencilla demostraci\u00f3n de c\u00f3mo insertar un documento:<\/p>\n Y luego la concordancia de patrones en el resultado de Try:<\/p>\n (Por supuesto, una aplicaci\u00f3n de producci\u00f3n gestionar\u00eda los errores adecuadamente, en lugar de limitarse a utilizar println).<\/p>\n Si prefieres tener algo similar al SDK de Java, que lanza excepciones, esto es f\u00e1cil de simular simplemente llamando a .get() en cualquier Try, que lanzar\u00e1 si es un Failure:<\/p>\n Es f\u00e1cil combinar m\u00faltiples Try's a trav\u00e9s de flatMap. Aqu\u00ed insertamos un documento, luego lo obtenemos, recuperamos su contenido convertido a la librer\u00eda JSON JsonObjectSafe (m\u00e1s sobre esto m\u00e1s adelante), y finalmente obtenemos un campo llamado \"status\" a partir de \u00e9l. Todo en un estilo completamente funcional, as\u00ed que por ejemplo la operaci\u00f3n get s\u00f3lo se intentar\u00e1 si el upsert tiene \u00e9xito.<\/p>\n (En aras de la concisi\u00f3n, en la mayor\u00eda de los ejemplos no se comprobar\u00e1 el resultado. Pero las aplicaciones de producci\u00f3n deber\u00edan, por supuesto, ABC - siempre comprobarlo).<\/p>\n Fuera de la caja, el SDK soporta la nueva durabilidad m\u00e1s fuerte que estar\u00e1 disponible en Couchbase Server 6.5:<\/p>\n E incorpora soporte para colecciones, un nuevo m\u00e9todo de organizar documentos dentro de cubos que ser\u00e1 una caracter\u00edstica fundamental de una futura versi\u00f3n de Couchbase Server (con una vista previa en breve). Pronto se podr\u00e1n crear algunas colecciones de juguete con las que jugar, pero por ahora bastar\u00e1 con abrir la colecci\u00f3n por defecto:<\/p>\n Esta l\u00f3gica funcionar\u00e1 en todas las versiones soportadas de Couchbase Server (5.x y superiores).<\/p>\n Adem\u00e1s, se incluye compatibilidad con OpenTracing (ahora OpenTelemetry), la plataforma que se est\u00e1 convirtiendo en el est\u00e1ndar de facto para rastrear sistemas distribuidos complejos:<\/p>\n El SDK utiliza par\u00e1metros con nombre y por defecto en lugar de sobrecargas, por lo que el c\u00f3digo puede ser muy sencillo:<\/p>\n o a medida:<\/p>\n como usted necesita que sea.<\/p>\n Al igual que el SDK de Java, se presentan tres API, que le ofrecen la flexibilidad necesaria para estructurar su aplicaci\u00f3n de la forma que necesite.<\/p>\n La primera es la API sincr\u00f3nica de bloqueo simple que has visto en los ejemplos anteriores. Esta puede ser una buena opci\u00f3n por defecto, pero por supuesto requiere que gestiones expl\u00edcitamente tus propios hilos si es necesario.<\/p>\n El segundo es uno construido en torno a la programaci\u00f3n reactiva, utilizando tipos reactivos est\u00e1ndar (Mono y Flux) del Proyecto Reactor.<\/p>\n Un ejemplo de upserting de forma reactiva:<\/p>\n Con la programaci\u00f3n reactiva, no ocurrir\u00e1 nada hasta que nos suscribamos al Mono. La forma m\u00e1s sencilla de hacer esto con fines de prueba es utilizar block(), aunque esto es una mala pr\u00e1ctica para una aplicaci\u00f3n real:<\/p>\n La programaci\u00f3n reactiva es un tema complejo y profundo en el que no puedo profundizar demasiado aqu\u00ed, pero cuando se domina proporciona una herramienta poderosa, especialmente para manejar las complejidades de los sistemas distribuidos del mundo real. En particular, la API reactiva proporciona backpressure en N1QL, FTS y consultas anal\u00edticas - por lo que si la aplicaci\u00f3n est\u00e1 luchando para mantenerse al d\u00eda con los datos, se ralentizar\u00e1 autom\u00e1ticamente el consumo de filas y evitar errores fuera de memoria. Animo a los curiosos a echar un vistazo a la Documentaci\u00f3n del proyecto Reactor<\/a> para saber m\u00e1s.<\/p>\n Por \u00faltimo, est\u00e1 la API as\u00edncrona construida alrededor de Scala Futures, que proporciona un poco de la gesti\u00f3n de hilos y composabilidad de la programaci\u00f3n reactiva, pero en una forma que es m\u00e1s familiar para muchos desarrolladores Scala. Un ejemplo simple de upsert se ve as\u00ed:<\/p>\n Uno de los principales objetivos era no ce\u00f1irte a ninguna implementaci\u00f3n JSON en particular, y el SDK de Scala funciona bien con varias librer\u00edas JSON populares de Scala, incluyendo Circe, \u00b5Pickle \/ \u00b5Json, Json4s y Jawn. Puedes ver fragmentos de c\u00f3mo usar cada una de ellas en los documentos JSON<\/a>Pero para abrir el apetito, aqu\u00ed tiene Circe en acci\u00f3n: observe c\u00f3mo los tipos Circe se env\u00edan y devuelven directamente al SDK:<\/p>\n Tomando un enfoque de \"pilas incluidas\" tambi\u00e9n hay una sencilla biblioteca JSON incluida con el SDK, JsonObject. Sus principales objetivos son:<\/p>\n Puede profundizar en la Documentaci\u00f3n sobre JsonObject<\/a>. Por supuesto, si prefieres tener una librer\u00eda JSON m\u00e1s 't\u00edpicamente Scala' con datos inmutables, tipos de datos algebraicos, lentes, cursores y otras bondades funcionales, entonces una de las otras librer\u00edas soportadas puede ser una mejor elecci\u00f3n - la elecci\u00f3n es tuya, y puedes f\u00e1cilmente mezclar y combinar m\u00faltiples librer\u00edas JSON en la misma aplicaci\u00f3n.<\/p>\n Aunque el SDK de Scala tiene un gran soporte para JSON, a veces es m\u00e1s f\u00e1cil y preferible trabajar directamente con las clases de casos de Scala.<\/p>\n Con s\u00f3lo a\u00f1adir este peque\u00f1o trozo de boilerplate para tu clase case, el SDK puede generar autom\u00e1ticamente la l\u00f3gica de serializaci\u00f3n:<\/p>\n Y entonces usted puede f\u00e1cilmente enviar esa clase de caso directamente a, y recibirla de vuelta de, el SDK:<\/p>\n Bajo el cap\u00f3 esto se convierte y se almacena en Couchbase Server como el JSON que usted esperar\u00eda:<\/p>\n Se trata de JSON normal y corriente, sin metadatos de serializaci\u00f3n adicionales o similares, por lo que puede escribirse libremente como una clase de caso y leerse en una biblioteca JSON o por otro SDK, o viceversa.<\/p>\n Echa un vistazo a la documentaci\u00f3n sobre el uso de clases de casos<\/a> para saber m\u00e1s.<\/p>\n Hemos facilitado al m\u00e1ximo el uso de Couchbase Analytics, N1QL y Full Text Search. Aqu\u00ed hay un ejemplo de una consulta N1QL donde las filas se convierten en JsonObject.<\/p>\n Y por supuesto es posible obtener esos resultados como cualquiera de los tipos JSON soportados arriba, o directamente como clases de casos Scala.<\/p>\n Y como ya se ha mencionado, el uso de la API reactiva significa que se obtiene backpressure autom\u00e1tico de forma gratuita, lo que garantiza que la aplicaci\u00f3n consuma filas a un ritmo manejable y no pueda encontrarse con problemas de falta de memoria en consultas muy grandes.<\/p>\n <\/p>\n Si quieres empezar a utilizar el SDK Scala de Couchbase, echa un vistazo a la secci\u00f3n gu\u00eda de inicio r\u00e1pido<\/a>. Ya est\u00e1 disponible, aunque en fase alfa. Puede que haya algunos cambios de \u00faltima hora antes de pasar a GA, pero por otro lado este es el momento perfecto para probarlo y darnos tu opini\u00f3n dejando un comentario a continuaci\u00f3n, o plante\u00e1ndolo en nuestros foros<\/a>, Twitter<\/a> o gitter<\/a>. Nada es inamovible y agradecemos la oportunidad de hacer algunos cambios y convertirlo en el mejor SDK posible.<\/p>","protected":false},"excerpt":{"rendered":" I\u2019m very happy to report that Couchbase now has a supported Scala SDK, allowing you to get and fetch documents, run N1QL queries, perform analytics and full text search lookups – all with native Scala. In this blog I\u2019m going […]<\/p>","protected":false},"author":40102,"featured_media":7088,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_acf_changed":false,"inline_featured_image":false,"footnotes":""},"categories":[2201],"tags":[],"ppma_author":[9084],"class_list":["post-7085","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-tools-sdks"],"acf":[],"yoast_head":"\nTratamiento funcional de errores: \u00a1sin excepciones!<\/b><\/h3>\n
val json = JsonObject(\"status\" -> \"awesome!\")\r\n\r\nval result: Try[MutationResult] = collection.insert(\"document-key\", json)<\/pre>\n
result match {\r\n \u00a0\u00a0\u00a0 case Success(mr) => println(\"Upsert was successful\")\r\n \u00a0\u00a0\u00a0 case Failure(err: KeyAlreadyExistsException) => println(\"document-key already exists\") \r\n \u00a0\u00a0\u00a0 case Failure(err) => println(\"Error: \" + err)\r\n}<\/pre>\nval result: MutationResult = collection.insert(\"document-key\", json).get()<\/pre>\n
val result: Try[String] = collection.upsert(\"document-key\", json)\r\n .flatMap(_ => collection.get(\"document-key\"))\r\n .flatMap(_.contentAs[JsonObjectSafe])\r\n .flatMap(_.str(\"status\"))\r\n\r\nresult match {\r\n case Success(status) => println(s\"Couchbase is $status\")\r\n case Failure(err) =>\u00a0\u00a0\u00a0 println(\"Error: \" + err)\r\n}<\/pre>\nPrevisi\u00f3n<\/b><\/h3>\n
val result = collection.upsert(\u201cdocId\u201d, json, durability = Durability.Majority)<\/pre>\n
val cluster = Cluster.connect(\"cluster-ip\", \"username\", \"password\")\r\nval collection = cluster.bucket(\"bucket-name\").defaultCollection<\/pre>\n
val result = collection.upsert(\u201cdocId\u201d, json, parentSpan = Some(mySpan))<\/pre>\n
API simple<\/b><\/h3>\n
val result = collection.upsert(\u201cdocId\u201d, json)<\/pre>\n
val result = collection.upsert(\u201cdocId\u201d, json, durability = Durability.Majority, expiration = 60.minutes, parentSpan = Some(mySpan))<\/pre>\n
As\u00edncrono<\/b><\/h3>\n
val mono: Mono[MutationResult] = collection.reactive.upsert(\"document-key\", json)\r\n .doOnError(err => println(s\"Error during upsert: ${err}\"))\r\n .doOnNext(mutationResult => println(\"Success\"))<\/pre>\nval result: MutationResult = mono.block()<\/pre>\n
val result: Future[MutationResult] = collection.async.upsert(\"document-key\", json)\r\n\r\nresult onComplete {\r\n case Success(_) \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 => println(\"Successfully upserted\")\r\n case Failure(exception) => println(\"Error: \" + exception)\r\n}<\/pre>\nFlexibilidad JSON<\/b><\/h3>\n
import io.circe.generic.auto._\r\nimport io.circe.syntax._\r\n\r\nval user = User(\u201cJohn Smith\u201d, 29)\r\nval json: io.circe.Json = user.asJson\r\n\r\nval result: Try[io.circe.Json] = collection.insert(\"id\", json)\r\n .flatMap(_ => collection.get(\"id\"))\r\n .flatMap(doc => doc.contentAs[io.circe.Json])\r\n\r\nresult match {\r\n case Success(content: io.circe.Json) =>\r\n \/\/ Handle Circe Json here\r\n case Failure(err) =>\u00a0\u00a0\u00a0 println(\"Error: \" + err)\r\n}<\/pre>\nJSON integrado<\/h4>\n
\n
Apoyo directo a las clases de casos<\/b><\/h4>\n
case class User(name: String, age: Int)\r\n\r\nobject User {\r\n implicit val codec: Codec[User] = Codecs.codec[User]\r\n}<\/pre>\nval r: Try[User] = collection.insert(\u201cdocId\u201d, User(\u201cJohn Smith\u201d, 29))\r\n .flatMap(_ => collection.get(\u201cdocId\u201d)\r\n .flatMap(doc => doc.contentAs[User])<\/pre>\n
{\"name\":\"John Smith\",\"age\":29}<\/pre>\nConsultas sencillas<\/b><\/h3>\n
cluster.query(\"\"\"select * from `travel-sample` limit 10;\"\"\")\r\n .flatMap(_.allRowsAs[JsonObject]) match {\r\n\r\n case Success(rows: Seq[JsonObject]) =>\r\n rows.foreach(row => println(row))\r\n case Failure(err) =>\r\n println(s\"Error: $err\")\r\n}<\/pre>\n