AskOverflow.Dev

AskOverflow.Dev Logo AskOverflow.Dev Logo

AskOverflow.Dev Navigation

    • Início
    • system&network
    • Ubuntu
    • Unix
    • DBA
    • Computer
    • Coding
    • LangChain

Mobile menu

Close
  • Início
  • system&network
    • Recentes
    • Highest score
    • tags
  • Ubuntu
    • Recentes
    • Highest score
    • tags
  • Unix
    • Recentes
    • tags
  • DBA
    • Recentes
    • tags
  • Computer
    • Recentes
    • tags
  • Coding
    • Recentes
    • tags
Início / coding / 问题

Perguntas[scala](coding)

Martin Hope
codeaperature
Asked: 2025-04-30 01:33:49 +0800 CST

Correspondência de padrões Scala em função passada

  • 6

Como um padrão corresponde ao Sucesso ou ao Falha neste método:

trait FunctionApi:
     def computeTry(funct: Try[String] => Unit): Unit = ??? // some ops

def actUponTry(functionApi: FunctionApi): String = {

     // This below could be something other than match as 
     // long as `Success` or `Failure` is apparent)

     functionApi.computeTry(...) match
     // When Try is ... (get Try + exception or value)
     // Success(value) => // Act on Success & value
                  s"Success with $value" 
     // Failure(ex) =>    // Act on Failure & ex 
                  s"Failure with exception ${ex.getString}"

}

E se FunctionApihouver outro método chamado computeTry2is computeTry2(funct: Try[Long] => Unit): Unit, esse "teste de correspondência" pode ser mais genérico?

Não use bibliotecas externas.

Talvez Como fazer a correspondência de padrões de uma função em Scala? seja útil?

Talvez haja uma maneira de usar outra característica ou método wrapper para extrair os parâmetros de Sucesso/Falha?

EDIÇÃO ADICIONAL:

O objetivo final é atribuir uma Promessa para promulgar um Futuro. (Quero fazer essa parte sozinho.) O código de chamada poderia ser assim:

val success = Success("Some String")
val succeeding = new FunctionApi:
    def computeTry(continuation: Try[String] => Unit): Unit =
        continuation(success)
val wasSuccess = actUponTry(succeeding).computeTry()
    

EDIÇÃO #2: Consegui fazer isso funcionar. Vou fechar este problema conforme ele evoluiu.

  def actUponTry(functionApi: FunctionBasedApi): StringBasedApi = {
    class StringBasedApiX extends StringBasedApi {
      def computeTry(): String = {
        functionApi.computeTry {
          case Success(value) => s"Success with $value"
          case Failure(ex) => s"Failure with exception ${ex.getMessage}"
        }
      }
    }
    new StringBasedApiX
  }

/**
  * Dummy example of a callback-based API
  */

trait FunctionBasedApi:
  def computeTry(funct: Try[String] => String): String

  /**
   * API similar to [[CallbackBasedApi]], but based on `String` instead
   */
trait StringBasedApi:
  def computeTry(): String

com código de teste:

  test("test matching") {
    val success = Success("Some String")
    val stringBasedApi = new FunctionBasedApi:
      def computeTry(funct: Try[String] => String): String = funct(success)
    val wasSuccess = actUponTry(stringBasedApi).computeTry()
    assertEquals(wasSuccess,  s"Success with ${success.get}")
  }

Mas descobri que a maneira como eu estava tentando fazer isso com futuros funciona de forma diferente do código acima (acima... Não consegui fazer a correspondência do padrão).

scala
  • 1 respostas
  • 58 Views
Martin Hope
Wallace
Asked: 2025-03-29 05:38:36 +0800 CST

No script Scala, evite "Falha ao carregar a classe org.slf4j.impl.StaticLoggerBinder"

  • 5

Ao executar meu script Scala, vejo um aviso:

> scala upload.scala

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.

Aqui está meu script:

//> using scala "3"
//> using dep "software.amazon.awssdk:s3:2.31.10"

import software.amazon.awssdk.services.s3.S3Client

@main
def main() = S3Client.builder()

Pergunta : Como posso evitar esse aviso?

scala
  • 1 respostas
  • 48 Views
Martin Hope
Wallace
Asked: 2025-03-29 03:52:18 +0800 CST

Importar/incluir/usar objetos de outro arquivo de origem em um arquivo de script Scala

  • 6

Eu tenho um MyScript.scalaarquivo:

//> using scala "3"

object MyUtils {
  def sayHello() = println("Hello")
}

@main
def main(): Unit =
  MyUtils.sayHello();

Eu o executei com sucesso assim:

> scala MyScript.scala

Compiling project (Scala 3.6.4, JVM (17))
Compiled project (Scala 3.6.4, JVM (17))
Hello

Pergunta : O que preciso fazer para mover meu MyUtilsobjeto para outro arquivo de origem (por exemplo, MyUtils.scalaou MyUtils.sc) e ainda chamar o sayHellométodo de dentro MyScript.scala?

scala
  • 1 respostas
  • 31 Views
Martin Hope
vikrant rana
Asked: 2025-02-19 09:59:14 +0800 CST

anexando a Seq[String] vazio

  • 5

Eu estava tentando anexar um Seq[String]a um vazio existenteSeq[String]

var enrichmentColumnsList: Seq[String] = Seq.empty
datasetEnricherConf.map(u => u.columnMappingsConf).foreach {
  columnMappingConf =>
    for (i <- 0 to columnMappingConf.size) {
      var cond = columnMappingConf.map(_.destColumnName)
      println(s"cond:$cond")
      enrichmentColumnsList= cond
    }
}


println(s"enrichmentColumnsList:$enrichmentColumnsList")

cond:List(NODE)
cond:List(NODE)
cond:List(NODE_temp, NETWORK, SITETYPE, STATEORPROVINCE, DISTRICT, CLUSTER, REGION)
cond:List(NODE_temp, NETWORK, SITETYPE, STATEORPROVINCE, DISTRICT, CLUSTER, REGION)
cond:List(NODE_temp, NETWORK, SITETYPE, STATEORPROVINCE, DISTRICT, CLUSTER, REGION)
cond:List(NODE_temp, NETWORK, SITETYPE, STATEORPROVINCE, DISTRICT, CLUSTER, REGION)
cond:List(NODE_temp, NETWORK, SITETYPE, STATEORPROVINCE, DISTRICT, CLUSTER, REGION)
cond:List(NODE_temp, NETWORK, SITETYPE, STATEORPROVINCE, DISTRICT, CLUSTER, REGION)
cond:List(NODE_temp, NETWORK, SITETYPE, STATEORPROVINCE, DISTRICT, CLUSTER, REGION)
cond:List(NODE_temp, NETWORK, SITETYPE, STATEORPROVINCE, DISTRICT, CLUSTER, REGION)
enrichmentColumnsList:List(NODE_temp, NETWORK, SITETYPE, STATEORPROVINCE, DISTRICT, CLUSTER, REGION)

Ele inicializa com a última ocorrência da lista.

Eu esperava algo como abaixo:

enrichmentColumnsList:List(NODE,NODE_temp, NETWORK, SITETYPE, STATEORPROVINCE, DISTRICT, CLUSTER, REGION)
scala
  • 1 respostas
  • 42 Views
Martin Hope
VinchikLenin
Asked: 2025-02-15 00:06:18 +0800 CST

Scala bot4s: não foi possível encontrar valor implícito para o parâmetro backend: sttp.client3.SttpBackend[scala.concurrent.Future,Any]

  • 6

Copiei o código do repositório telegram/bot4s, coloquei parte do código em "object Main extends App", criei o arquivo sbt e instalei as bibliotecas.

import cats.instances.future._
import cats.syntax.functor._
import com.bot4s.telegram.api.RequestHandler
import com.bot4s.telegram.api.declarative.Commands
import com.bot4s.telegram.clients.{FutureSttpClient, ScalajHttpClient}
import com.bot4s.telegram.future.{Polling, TelegramBot}
import com.bot4s.telegram.methods.SendDice

import scala.util.Try
import scala.concurrent.Future

/** Generates random values.
 */


class RandomBot(val token: String) extends TelegramBot
  with Polling
  with Commands[Future] {

  //LoggerConfig.factory = PrintLoggerFactory()
  // set log level, e.g. to TRACE
  //LoggerConfig.level = LogLevel.TRACE

  // Use sttp-based backend
  implicit val backend = SttpBackends.default
  override val client: RequestHandler[Future] = new FutureSttpClient(token)

  // Or just the scalaj-http backend
  // override val client: RequestHandler[Future] = new ScalajHttpClient(token)

  val rng = new scala.util.Random(System.currentTimeMillis())
  onCommand("coin" or "flip") { implicit msg =>
    reply(if (rng.nextBoolean()) "Head!" else "Tail!").void
  }
  onCommand("real" | "double" | "float") { implicit msg =>
    reply(rng.nextDouble().toString).void
  }
  onCommand("/die" | "roll") { implicit msg =>
    reply("⚀⚁⚂⚃⚄⚅" (rng.nextInt(6)).toString).void
  }
  onCommand("random" or "rnd") { implicit msg =>
    withArgs {
      case Seq(Int(n)) if n > 0 =>
        reply(rng.nextInt(n).toString).void
      case _ => reply("Invalid argumentヽ(ಠ_ಠ)ノ").void
    }
  }
  onCommand("choose" | "pick" | "select") { implicit msg =>
    withArgs { args =>
      replyMd(if (args.isEmpty) "No arguments provided." else args(rng.nextInt(args.size))).void
    }
  }

  onCommand("auto") { implicit msg =>
    request(SendDice(msg.chat.id)).void
  }
  // Extractor
  object Int {
    def unapply(s: String): Option[Int] = Try(s.toInt).toOption
  }
}


object Main extends App {
  val bot = new RandomBot("tokenhere")
  val eol = bot.run()
  println("Press [ENTER] to shutdown the bot, it may take a few seconds...")
  scala.io.StdIn.readLine()
  bot.shutdown() // initiate shutdown
  // Wait for the bot end-of-life
  Await.result(eol, Duration.Inf)
}

ThisBuild / version := "0.1.0-SNAPSHOT"

ThisBuild / scalaVersion := "2.13.16"

lazy val root = (project in file("."))
  .settings(
    name := "Meower"
  )

// Core with minimal dependencies, enough to spawn your first bot.
libraryDependencies += "com.bot4s" %% "telegram-core" % "5.8.4"

// Extra goodies: Webhooks, support for games, bindings for actors.
libraryDependencies += "com.bot4s" %% "telegram-akka" % "5.8.4"

mas depois disso falhei na construção com:

C:\Usuários\днс\Music\play-samples-3.0.x\Meower\src\main\scala\Main.scala:25:26 não encontrado: valor SttpBackends val implícito backend = SttpBackends.default

C:\Users\днс\Music\play-samples-3.0.x\Meower\src\main\scala\Main.scala:26:49 não foi possível encontrar o valor implícito para o parâmetro backend: sttp.client3.SttpBackend[scala.concurrent.Future,Any] Ocorreu um erro em um aplicativo envolvendo argumentos padrão. override val client: RequestHandler[Future] = new FutureSttpClient(token)

C:\Usuários\днс\Music\play-samples-3.0.x\Meower\src\main\scala\Main.scala:71:3 não encontrado: valor Await Await.result(eol, Duration.Inf)

C:\Usuários\днс\Music\play-samples-3.0.x\Meower\src\main\scala\Main.scala:71:21 não encontrado: valor Duration Await.result(eol, Duration.Inf)

O que preciso fazer para corrigir esses problemas?

Pesquisei "Não é possível encontrar SttpBackends + "Ocorreu um erro em um aplicativo envolvendo argumentos padrão." e tentei corrigir meu código, mas não obtive sucesso...

scala
  • 1 respostas
  • 26 Views
Martin Hope
Kris Rice
Asked: 2025-02-14 18:12:59 +0800 CST

Como adicionar um comportamento de recebimento "padrão" a um ator AKKA que é capaz de alterar seu comportamento?

  • 5

Fundo:

Eu tenho um Actor chamado Peer. Dentro da minha aplicação, a Peerrepresenta uma conexão entre o servidor que o criou e outro servidor. É essencialmente um http-client.

Quando a instância é executada pela primeira vez, o PeerManagerconsulta o banco de dados para obter a lista de entradas do servidor. Em seguida, ele cria um Peerator para esse servidor. O estado do Peerdepende de seu RegistrationStatuscampo ( PENDING_OUT , PENDING_IN , REGISTERED , ...)

A Peertem uma função de recebimento padrão que se parece com esta:

  override def receive: Receive = {
    case FirstTick =>
      system.log.info("receive FirstTick")
      timers.startTimerWithFixedDelay(TickKey, Tick, FiniteDuration(2, TimeUnit.SECONDS))
    case Tick =>
      system.log.info("receive Tick")
      // process every state until all are complete
      var statesLeft = false
      
      states = states.sortWith{ (s1, s2) => s1.order > s2.order }

      for (state <- states) {
        if (!state.complete) {
          statesLeft = true
          if (state.waitForPing) {
            context.become(pingService(state))
          } else {
            context.become(state.behavior)
          }
        }
      }

      if (!statesLeft) context.become(pingService(null))
  }

Isso basicamente permite a Peertransição por uma lista de estados, executando o comportamento de cada estado até que ele esteja completo.

Um conjunto de estados pode se parecer com isto:

    case PENDING_OUT =>
        Seq(
          new InitState(0, peer),
          new SessionHandshake(1, peer),
          new WaitMessages(2, peer)
        )

Um exemplo de um dos estados:

class WaitAccept(order: Int, peer: Peer)(implicit system: ActorSystem) extends PeerState(order, false, true) {

  override def behavior: Receive = {
    case Tick =>
      system.log.info("Waiting for accept")
      if (complete) peer.getContext.unbecome()

    case rA@RegistrationAccept(serverID, serverIP, _) =>
      system.log.info(s"Processing RegistrationAccept: ${rA.toProtoString}")
      complete = true
  }
  
}

PeerStatesuperclasse:

abstract case class PeerState(var order: Int, var complete: Boolean, var waitForPing: Boolean) {

  def behavior: Receive // <- must be overridden
  
}

Esse estado faz com que o peer fique sentado esperando por uma mensagem 'RegistrationAccept', gerada quando o usuário clica em 'Aceitar' na página da web.

O problema:

Alguns dos estados (por exemplo, Handshakeo estado que é responsável por trocar chaves de criptografia) enviam httpmensagens para o serverque o Peeré gerado para. Se a instância que recebe a mensagem encontrar um Peercom o solicitado serverID, o PeerManagerencaminhará essa mensagem para o Peerusando askassim:

case peerRequest@PeerRequest(serverID, SessionRequest(sessionRequest), _) =>
      // get the relevant peer for the requested serverID
      val peerEntry = peerMap.get(serverID)
      if (peerEntry.isDefined) {
        // ask the peer Actor for a response to the sessionRequest, block and wait for this response, then send it back to the peerManager

        val peerState = queryPeerState(peerEntry.get)    // <-- the issue

        if (peerState.isInstanceOf[SessionHandshake]) {  // <-- the issue
          try {
            sender() ! Await.result((peerEntry.get ? (self, sessionRequest)).mapTo[PeerResponse.Response], timeout.duration)
          } catch {
            case e: TimeoutException =>
              sender() ! PeerResponse.Response.StatusResponse(HydraStatusCodes.PEER_MANAGER_TIMEOUT.getStatusResponse)
          }
        } else {
          sender() ! PeerResponse.Response.StatusResponse(HydraStatusCodes.PEER_NOT_READY.getStatusResponse)
        }
      } else {
        sender() ! PeerResponse.Response.StatusResponse(HydraStatusCodes.PEER_NOT_READY.getStatusResponse)
      }

O problema ocorre quando a outra instância Peernão está no estado correto para receber a mensagem. Se isso acontecer, eu gostaria de responder com o apropriado HydraStatusCode. A abordagem mais normal para mim é de alguma forma perguntar em Peerque estado ela está antes de encaminhar a mensagem e, se estiver no estado errado, retornar o StatusCode apropriado.

No entanto, para conseguir isso, eu teria que implementar QueryStatecase em todos os lugares em que tenho Receivecomportamento. Isso parece desajeitado e bagunçado e, como um engenheiro habilidoso, não sinto que seja a maneira certa de fazer isso.

Gostaria de implementar isso de alguma forma na PeerStateclasse como comportamento padrão que sempre é chamado para um QueryState, ou de alguma forma permitir que eles PeerManagerchamem uma referência ao Peerobjeto diretamente em vez de ao ActorRef (mas sei que isso não é possível)

Existe alguma outra abordagem para isso ou a maneira mais bagunçada é provavelmente a melhor?

scala
  • 1 respostas
  • 41 Views
Martin Hope
Lindenes
Asked: 2025-02-13 04:47:10 +0800 CST

conversação de classe de caso scala para DTO (shapeless)

  • 5

Quero converter a classe de caso UserDTO para a classe de caso User. Encontro a solução na conversão de classe de caso sem forma.

class SameFieldConverter[T] {
def apply[S, SR <: HList, TR <: HList, MR <: HList, IR <: HList](s: S)(implicit
  genS: LabelledGeneric.Aux[S, SR],
  genT: LabelledGeneric.Aux[T, TR],
  merger: Merger.Aux[SR, HNil, MR],
  intersection: Intersection.Aux[MR, TR, IR],
  align: Align[IR, TR]) = genT.from(intersection(merger(genS.to(s), HNil)))

mas tenho problemas com campos diferentes, por exemplo, em UserDTO tenho o nome do campo, sobrenome, mas em User tenho o nome completo.

  case class UserDTO(name:String, surname:String, age:Int){
    def toDomain:User = User(name + surname, age)
  }
  case class User(fullName:String, age:Int)

Também tenho problemas com nomes de campos diferentes, por exemplo, nome -> sobrenome

case class UserDTO(name:String, surname:String, age:Int)
case class User(firstName:String, surname:String, age:Int)

Eu penso sobre a solução como em um alias de pena ("nome", _.surname), mas tenho um cérebro pequeno. Eu também estava pensando em olhar para o uso da API de reflexão scala

scala
  • 1 respostas
  • 46 Views
Martin Hope
Kris Rice
Asked: 2025-02-12 05:52:42 +0800 CST

javax.net.ssl.SSLHandshakeException: (certificate_unknown) no cliente Scala via NGINX

  • 7

Problema:

Fiquei indo e voltando na última semana ou mais tentando configurar meu cliente Scala+AKKA para poder enviar mensagens para um servidor executando o NGINX.

Continuo recebendo o erro: javax.net.ssl.SSLHandshakeException: (certificate_unknown)

Configurar:

nginxconfiguração:

server {
    listen 443 ssl default_server;
    listen [::]:443 ssl default_server;
    server_name localhost;

    ssl_certificate /home/hydra/.localhost-ssl/localhost.crt;           //<- combined certificates (server_cert + rootCA)
    ssl_certificate_key /home/hydra/.localhost-ssl/localhost-key.key;

    ssl_trusted_certificate /home/hydra/.localhost-ssl/rootCA.crt;      //<- just the rootCA

    index index.html index.htm;
    root /home/hydra/ui/;

    location / {
        try_files $uri.html $uri/index.html
        @public
        @nextjs;
        add_header Cache-Control "public, max-age=3600";
    }

    location @public {
        add_header Cache-Control "public, max-age=3600";
    }

    location /ping {
        proxy_pass http://localhost:8080;
    }

    location @nextjs {
            proxy_pass http://localhost:3000;
            proxy_http_version 1.1;
            proxy_set_header Upgrade $http_upgrade;
            proxy_set_header Connection 'upgrade';
            proxy_set_header Host $host;
            proxy_cache_bypass $http_upgrade;
            proxy_set_header X-Real-IP $remote_addr;
            proxy_set_header X-Forwarded-Proto https;
            proxy_set_header X-Forwarded-For $remote_addr;
            proxy_set_header X-Forwarded-Host $remote_addr;
    }
}

solicitação do cliente:


  private val sslContext: SSLContext = SSLManager.getClientSSLContext
  private val connectionContext = ConnectionContext.httpsClient(sslContext)

...

    val request = HttpRequest(method = HttpMethods.GET, uri = s"https://${server.serverIP}/ping")
    http.singleRequest(request, connectionContext).pipeTo(self)

createClientContext:

  def getClientSSLContext: SSLContext = {
    val keyStore = KeyStore.getInstance("JKS")
    keyStore.load(null, null) // Create an empty keystore
    keyStore.setCertificateEntry("rootCA", loadRootCertificate())

    // Set up a TrustManager that trusts the root CA certificate
    val trustManagerFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm)
    trustManagerFactory.init(keyStore)
    val trustManagers = trustManagerFactory.getTrustManagers

    // Create an SSLContext with the custom TrustManager
    val sslContext = SSLContext.getInstance("TLS")
    sslContext.init(null, trustManagers, new SecureRandom())
    sslContext
  }

Escrevendo rootCApara arquivo:

    val rootCA = new StringBuilder()
    rootCA.append("-----BEGIN CERTIFICATE-----\n")
    rootCA.append(Base64.getEncoder.encodeToString(rootCACertificate.getEncoded))
    rootCA.append("\n-----END CERTIFICATE-----")
    writeFile(ROOT_CA_PATH, Seq(rootCA.toString))

Como crio o certificado do servidor assinado:

def createCSR(keyPair: KeyPair, subject: String, keyAlgorithm: String): PKCS10CertificationRequest = {
    val csrGen = new PKCS10CertificationRequestBuilder(new X500Name(subject), SubjectPublicKeyInfo.getInstance(keyPair.getPublic.getEncoded))
    val signer = new JcaContentSignerBuilder("SHA256with" + keyAlgorithm).build(keyPair.getPrivate)
    csrGen.build(signer)
  }

  // Sign the CSR with the root CA's private key to generate a certificate
  def signCertificate(csr: PKCS10CertificationRequest, rootCACertificate: X509Certificate, rootCAPrivateKey: PrivateKey): X509Certificate = {
    val notBefore = new Date()
    val notAfter = new Date(notBefore.getTime + 36500L * 24 * 60 * 60 * 1000) // Valid for 1 year

    val certGen = new X509v3CertificateBuilder(
      new X500Name("CN=Hydra SSL Certificate"),
      new BigInteger(128, new Random()),
      notBefore,
      notAfter,
      csr.getSubject,
      csr.getSubjectPublicKeyInfo
    )

    // Add SubjectAlternativeName (SAN) extension
    val sanNames = Array[GeneralName](
      new GeneralName(GeneralName.iPAddress, SERVER_IP)
    )

    val generalNames = new GeneralNames(sanNames)
    certGen.addExtension(Extension.subjectAlternativeName, false, generalNames)

    // Sign with root CA's private key
    val signer = new JcaContentSignerBuilder("SHA256withRSA").build(rootCAPrivateKey)
    val certificateHolder: X509CertificateHolder = certGen.build(signer)

    // Convert to a JCE certificate
    val converter = new JcaX509CertificateConverter().setProvider("BC")
    converter.getCertificate(certificateHolder)
  }

...

    // Step 1: Load Root CA certificate and private key
    val rootCACertificate = loadRootCertificate()
    val rootCAPrivateKey = loadRootPrivateKey()

    // Step 2: Generate new key pair for SSL certificate
    val keyPair = generateKey("RSA")

    // Step 3: Create CSR (Certificate Signing Request)
    val csr = createCSR(keyPair, s"CN=hydra_server_$SERVER_ID, O=Hydra, C=UK", "RSA")

    // Step 4: Sign the CSR with the Root CA to generate the SSL certificate
    val sslCertificate = signCertificate(csr, rootCACertificate, rootCAPrivateKey)

O que eu tentei:

Após consultar chatGPT, tentei o comandoopenssl s_client -connect 192.168.0.4:443 -showcerts

A saída deste comando pode ser encontrada aqui .

Isso me ajudou a verificar se, nginxde fato, estava enviando toda a cadeia, na ordem correta (pode ser confirmado pela data - o rootCA(certificado 1 na saída) foi gerado em 02/07/2025, o certificado do servidor (certificado 0) foi gerado hoje.

Então o que estou fazendo errado/perdendo na minha configuração?

scala
  • 1 respostas
  • 49 Views
Martin Hope
ashish.g
Asked: 2025-01-21 23:18:43 +0800 CST

Como ler corretamente um arquivo CSV escapando a vírgula delimitadora colocada entre colchetes usando Apache Spark e Scala?

  • 5

Tenho o seguinte CSV que é publicado por um terceiro com os valores para uma coluna específica contendo uma vírgula (por algum motivo inexplicável). Os valores para a coluna estão ausentes ou entre colchetes/aspas duplas, pois representam um intervalo.

A seguir está um desses registros do CSV:

A,B
xxxxxxxxx,"['05-01', '06-30']"
yyyyyyyyy,"['04-01', '04-30']"
zzzzzzzzz,

O culpado é a segunda coluna, como é óbvio. Existe uma maneira de analisar corretamente esse CSV no Apache Spark (Scala) para ter o seguinte dataframe:

+---+----------+------------------------+
|A             |B                       |
+---+-----------------------------------+
|xxxxxxxxx     |"['05-01', '06-30']"    |
|yyyyyyyyy     |"['04-01', '04-30']"    |
|zzzzzzzzz     |null                    |
+---+----------+------------------------+
scala
  • 1 respostas
  • 27 Views
Martin Hope
Kris Rice
Asked: 2025-01-18 03:47:49 +0800 CST

Como manter referência a uma instância criada da classe Actor com Akka?

  • 5

Tenho uma classe que é um Ator:

class Client(server: Server, systemActor: ActorRef) extends Actor {
...
}

Tenho uma lista que gerencia clientes conectados. O ator que gera os atores clientes observa uma lista de "servidores" no banco de dados e gera uma conexão de cliente para cada um, assim:

private val clientList = mutable.ArrayBuffer.empty[Client]

class RegistrationWatcherActor(val systemActor: ActorSystem) extends Actor with Timers {

  implicit val system: ActorSystem = context.system

  timers.startSingleTimer(TickKey, FirstTick, FiniteDuration(1, TimeUnit.SECONDS)) // wait 10 seconds to give database time to initiate

  private def checkRegistrations(): Unit = {
    val database = DatabaseUtil.getInstance
    val serversOutgoing: Seq[Server] = database.getAll[Server](classOf[Server])

    for (server <- serversOutgoing) {
      val client = clientList.find{ client => client.server == server }
      if (client.isEmpty) { // client for this server was not found, so create one
        
      }
    }
  }

  def receive: Receive = {
    case FirstTick =>
      timers.startTimerWithFixedDelay(TickKey, Tick, FiniteDuration(1, TimeUnit.SECONDS))
    case Tick =>
      checkRegistrations()
  }
}

O Problema

Na verificação, if (client.isEmpty)gostaria de criar uma instância de Client, gerá-la como um ator e colocar a referência na lista para que ela não seja criada novamente. Como você pode ver, meu método de identificar se o cliente foi criado ou não é verificar se ele está serverIDarmazenado no banco de dados.

O ideal é fazer:

val client = new Client(server, systemActor)
systemActor.actorOf(Props(client), server.serverID)
clientList.append(client)

Alguma sugestão, por favor?

Alternativa

Percebi que posso fazer clientListuma lista de Stringe armazenar o serverIDaqui. No entanto, eventualmente gostaria que o RegistrationWatcherpudesse ter controle sobre aspectos do cliente, então uma referência ao Clientobjeto seria preferível.

scala
  • 1 respostas
  • 38 Views

Sidebar

Stats

  • Perguntas 205573
  • respostas 270741
  • best respostas 135370
  • utilizador 68524
  • Highest score
  • respostas
  • Marko Smith

    Reformatar números, inserindo separadores em posições fixas

    • 6 respostas
  • Marko Smith

    Por que os conceitos do C++20 causam erros de restrição cíclica, enquanto o SFINAE antigo não?

    • 2 respostas
  • Marko Smith

    Problema com extensão desinstalada automaticamente do VScode (tema Material)

    • 2 respostas
  • Marko Smith

    Vue 3: Erro na criação "Identificador esperado, mas encontrado 'import'" [duplicado]

    • 1 respostas
  • Marko Smith

    Qual é o propósito de `enum class` com um tipo subjacente especificado, mas sem enumeradores?

    • 1 respostas
  • Marko Smith

    Como faço para corrigir um erro MODULE_NOT_FOUND para um módulo que não importei manualmente?

    • 6 respostas
  • Marko Smith

    `(expression, lvalue) = rvalue` é uma atribuição válida em C ou C++? Por que alguns compiladores aceitam/rejeitam isso?

    • 3 respostas
  • Marko Smith

    Um programa vazio que não faz nada em C++ precisa de um heap de 204 KB, mas não em C

    • 1 respostas
  • Marko Smith

    PowerBI atualmente quebrado com BigQuery: problema de driver Simba com atualização do Windows

    • 2 respostas
  • Marko Smith

    AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos

    • 1 respostas
  • Martin Hope
    Fantastic Mr Fox Somente o tipo copiável não é aceito na implementação std::vector do MSVC 2025-04-23 06:40:49 +0800 CST
  • Martin Hope
    Howard Hinnant Encontre o próximo dia da semana usando o cronógrafo 2025-04-21 08:30:25 +0800 CST
  • Martin Hope
    Fedor O inicializador de membro do construtor pode incluir a inicialização de outro membro? 2025-04-15 01:01:44 +0800 CST
  • Martin Hope
    Petr Filipský Por que os conceitos do C++20 causam erros de restrição cíclica, enquanto o SFINAE antigo não? 2025-03-23 21:39:40 +0800 CST
  • Martin Hope
    Catskul O C++20 mudou para permitir a conversão de `type(&)[N]` de matriz de limites conhecidos para `type(&)[]` de matriz de limites desconhecidos? 2025-03-04 06:57:53 +0800 CST
  • Martin Hope
    Stefan Pochmann Como/por que {2,3,10} e {x,3,10} com x=2 são ordenados de forma diferente? 2025-01-13 23:24:07 +0800 CST
  • Martin Hope
    Chad Feller O ponto e vírgula agora é opcional em condicionais bash com [[ .. ]] na versão 5.2? 2024-10-21 05:50:33 +0800 CST
  • Martin Hope
    Wrench Por que um traço duplo (--) faz com que esta cláusula MariaDB seja avaliada como verdadeira? 2024-05-05 13:37:20 +0800 CST
  • Martin Hope
    Waket Zheng Por que `dict(id=1, **{'id': 2})` às vezes gera `KeyError: 'id'` em vez de um TypeError? 2024-05-04 14:19:19 +0800 CST
  • Martin Hope
    user924 AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos 2024-03-20 03:12:31 +0800 CST

Hot tag

python javascript c++ c# java typescript sql reactjs html

Explore

  • Início
  • Perguntas
    • Recentes
    • Highest score
  • tag
  • help
subwaysurfers
my femboy roommate

Footer

AskOverflow.Dev

About Us

  • About Us
  • Contact Us

Legal Stuff

  • Privacy Policy

Language

  • Pt
  • Server
  • Unix

© 2023 AskOverflow.DEV All Rights Reserve