All perguntas(coding)

Uma das minhas funções está gerando vários avisos que desejo testar testthat::expect_warning(). Eu poderia revisar o design, mas a documentação parece dizer que isso é possível, com o argumento deprecated all:

all: DEPRECATED Se você precisar testar vários avisos/mensagens, agora você precisa usar várias chamadas para expect_message()/expect_warning()

(Agradecimentos aos comentários após esta resposta )

No reprex a seguir (inspirado nos exemplos do documento), devtools::check()is passing. devtools::test()também está passando, mas também emite avisos (quando um aviso específico é testado, o outro é lançado).

Qual é a maneira correta de testar vários avisos, já que todos são esperados?

f1.R

f1 <- function(x) {
  if (x < 0) {
    warning("*x* is already negative")
    warning("this is a second warning")
    return(x)
  }
  -x
}

teste-f1.R

test_that("testing", {
 # Testing the function
  expect_equal(f1(2), -2)
 # Testing a generic warning
  expect_warning(f1(-1))
  # Testing the first warning
  expect_warning(f1(-1), "already negative")
  # Testing the second warning
  expect_warning(f1(-1), "second")
  # Testing no warning
  expect_warning(f1(1), NA)
})

Produção relevante detest()

Correspondente aexpect_warning(f1(-1))

Aviso (teste-f1.R:5:3): testar este é um segundo aviso

Correspondente aexpect_warning(f1(-1), "already negative")

Aviso (teste-f1.R:6:3): testar este é um segundo aviso

Correspondente aexpect_warning(f1(-1), "second")

Aviso (test-f1.R:7:3): o teste x já é negativo

Estou tentando consumir uma mensagem grande de um servidor ActiveMQ Artemis embarcado com um cliente Python que está se conectando usando STOMP. O cliente cria uma fila temporária e envia uma mensagem para um endereço de "solicitação". O servidor deve gerar uma resposta e enviá-la de volta para a fila temporária. Nesse caso, a resposta tem aproximadamente 2,8 milhões de JSON.

Quando o servidor tenta responder, recebo esta mensagem:

info: 11:49:10 372 [Thread-1 (ActiveMQ-server-ActiveMQServerImpl::name=localhost)] org.apache.activemq.audit.message   AMQ601500: User anonymous@invm:0 sent a message NullStorageLargeServerMessage[messageID=1145, durable=false, address=/temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6,properties=TypedProperties[_AMQ_LARGE_SIZE=5681703]], context: RoutingContextImpl(Address=/temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6, routingType=null, PreviousAddress=/temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6 previousRoute:null, reusable=true, version=-2147483639)
..................................................
***** durable queues /temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6:
***** non durable for /temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6:
- queueID=1139 address:/temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6 name:2ca84365-155a-11f0-b485-56de892bcc7e filter:null
..................................................
, transaction: null
info: 11:49:10 372 [Thread-3 (ActiveMQ-server-ActiveMQServerImpl::name=localhost)] org.apache.activemq.audit.message   AMQ601501: User [email protected]:64850 is consuming a message from 2ca84365-155a-11f0-b485-56de892bcc7e: Reference[1145]:NON-RELIABLE:NullStorageLargeServerMessage[messageID=1145, durable=false, address=/temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6,properties=TypedProperties[_AMQ_LARGE_SIZE=5681703]]
warning: 11:49:10 384 [Thread-3 (ActiveMQ-server-ActiveMQServerImpl::name=localhost)] org.apache.activemq.artemis.core.protocol.stomp   AMQ332071: Unable to send message to client: NullStorageLargeServerMessage[messageID=1145, durable=false, address=/temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6,properties=TypedProperties[_AMQ_LARGE_SIZE=5681703]] 
java.lang.IndexOutOfBoundsException null
    at io.netty.buffer.EmptyByteBuf.checkIndex(EmptyByteBuf.java:1042)
    at io.netty.buffer.EmptyByteBuf.writerIndex(EmptyByteBuf.java:150)
    at io.netty.buffer.WrappedByteBuf.writerIndex(WrappedByteBuf.java:132)
    at org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper.writerIndex(ChannelBufferWrapper.java:635)
    at org.apache.activemq.artemis.core.protocol.stomp.VersionedStompFrameHandler.populateFrameBodyFromLargeMessage(VersionedStompFrameHandler.java:394)
    at org.apache.activemq.artemis.core.protocol.stomp.VersionedStompFrameHandler.createMessageFrame(VersionedStompFrameHandler.java:341)
    at org.apache.activemq.artemis.core.protocol.stomp.v12.StompFrameHandlerV12.createMessageFrame(StompFrameHandlerV12.java:57)
    at org.apache.activemq.artemis.core.protocol.stomp.StompConnection.createStompMessage(StompConnection.java:649)
    at org.apache.activemq.artemis.core.protocol.stomp.StompSession.sendMessage(StompSession.java:170)
    at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1205)
    at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:522)
    at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:3812)
    at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:3058)
    at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:4157)
    at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:59)
    at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:32)
    at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:68)
    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
    at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:120)

Meu entendimento (provavelmente incorreto) é que o ActiveMQ Artemis deveria dividir isso em pedaços menores, mas ele está apenas me dando uma exceção.

Devo estar esquecendo alguma coisa (talvez uma configuração). Alguém pode me dizer o que é?

Estou usando o Artemis 2.40.0. Estou serializando meu objeto em JSON e enviando-o como uma mensagem de TEXTO:

Aqui está um pequeno programa que exibe esse comportamento:

public class Example {
    public static void main(String[] args) throws Exception {
        EmbeddedActiveMQ broker = new EmbeddedActiveMQ();
        broker.setConfigResourcePath("file:example.xml");
        broker.start();

        ServerLocator locator = ActiveMQClient.createServerLocator("vm://0");
        ClientSessionFactory clientSessionFactory = locator.createSessionFactory();
        ClientSession session = clientSessionFactory.createSession();
        session.start();

        ClientConsumer consumer = session.createConsumer("json.requests");
        consumer.setMessageHandler(new MessageHandler() {
            @Override
            public void onMessage(ClientMessage message) {
                byte[] bytes = new byte[message.getBodySize()];
                message.getBodyBuffer().readBytes(bytes);
                JsonElement jsonElement = JsonParser.parseString(new String(bytes));
                String replyTo = jsonElement.getAsJsonObject().get("reply-to").getAsString();
                String s = generateLargeMessage();
                try {
                    ClientProducer producer = session.createProducer("/temp-queue/" + replyTo);
                    ClientMessage m = session.createMessage(TEXT_TYPE, false);
                    m.getBodyBuffer().writeNullableSimpleString(SimpleString.of(s));
                    producer.send(m);
                    session.commit();
                } catch (ActiveMQException e) {
                    System.err.println("Couldn't send message: " + e.getMessage());
                }
            }
        });
    }

    private static String generateLargeMessage() {
        StringBuilder sb = new StringBuilder();
        while (sb.length() < 2000000) {
            sb.append("abcdefghijklmnopqrstuvwxyz\n");
        }
        return sb.toString();
    }
}

Aqui está meu xml:

<configuration xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="urn:activemq" xsi:schemaLocation="urn:activemq /schema/artemis-server.xsd">
    <core xmlns="urn:activemq:core">
        <persistence-enabled>false</persistence-enabled>
        <security-enabled>false</security-enabled>
        <acceptors>
            <acceptor name="in-vm">vm://0</acceptor>
            <acceptor name="in-tcp">tcp://localhost:61616</acceptor>
        </acceptors>

        <addresses>
            <address name="json.requests">
                <anycast>
                    <queue name="json.requests"/>
                </anycast>
            </address>
        </addresses>
    </core>
</configuration>

Aqui está meu teste python:

#!venv/bin/python3

import time
import stomp
import json
import uuid

myuuid = uuid.uuid4()
print(f"myuuid = {myuuid}")

conn = stomp.Connection12([('127.0.0.1', 61616)], heartbeats=(5000,5000))
conn.set_listener('', stomp.PrintingListener())

conn.connect(None, None, wait=True)

print("subscribing...")
conn.subscribe(destination=f"/temp-queue/{myuuid}", id=1, ack='auto')

msg = json.dumps({'type':'DaoRequest', 'request': 'users', 'reply-to': f"{myuuid}" })
print(f'sending {msg} to json.requests')

resp = conn.send(body=msg, destination="json.requests")
time.sleep(60)

Meus dados estão no seguinte formato simplificado

[
  {
    "a": "foo",
    "b": [
      {
        "x": 1,
        "y": true
      }
    ]
  },
  {
    "a": "foo",
    "b": [
      {
        "x": 1,
        "y": true
      },
      {
        "x": 99,
        "y": false
      }
    ]
  },
  {
    "a": "bar",
    "b": []
  }
]

Estou tentando obter a contagem de todas as entradas bpara cada elemento único a. Tentei primeiro agrupar por um, jq '. | group_by(.a)[]o que me dá pelo menos a aparte "único". No entanto, não consigo descobrir como obter a contagem de todas bas entradas dentro do resultado group_by. Simplesmente agrupar por b"like" jq '. | group_by(.a)[] | group_by(.b)[]'não funciona.

Como alternativa, tentei, jq -n 'jq '[ .[] | {a, n:(.b|length)} ] | group_by(.a)'mas ainda não sei como contar entradas .

Alguma sugestão? A resposta definitiva para este exemplo seria 3 bentradas para fooe 0 bentradas parabar

Usando cryptono pacote Haskell, estou tentando gerar a mesma saída, openssl dgstmas não consigo descobrir o que estou fazendo errado. Por favor, ajudem.

openssl dgst:

$ echo "TheMessage" | openssl dgst -sha256 -mac HMAC -macopt key:"TheKey"
SHA2-256(stdin)= 7b2e5669f4a5fa30a3fa0e9147f8975883cddff77725c99a6db07395b9665974

criptônio:

ghci> hmacGetDigest ( hmac ("TheKey" :: ByteString) ("TheMessage" :: ByteString) :: HMAC SHA256 )
39c17c48adbc2ea4d469af9ecb2569f921053843af2a0a7716b7a180b0cedff6

Obrigado.

Considere o seguinte programa:

#include <array>

int main() {
    throw std::logic_error("hi");
}

Com alguns compiladores C++ (ou melhor, bibliotecas padrão), isso compila. Por exemplo, libstdc++ 8, onde <array>inclui <stdexcept>. Mas em outras implementações de bibliotecas padrão, como libstdc++ 11, isso não compila.

Posso usar o clang-tity para me avisar sobre essas situações? Pelo menos em relação à biblioteca padrão?

Caso contrário, existe outra ferramenta, talvez não baseada em clang, que possa me ajudar a detectar esse problema?

Estou usando o pacote atakrig . Ao definir o número de núcleos como 8 para computação paralela, recebo este erro: 0%Error in serialize(data, node$con) : error writing to connection. Se eu definir o número de núcleos como 4, o processamento paralelo funciona bem (sem erros). Estou recebendo este erro quando uso a função do pacote ataStartCluster().

Encontrei uma solução alternativa para esse problema se eu definisse cl <- parallel::makeCluster(8, type = "PSOCK")em vez de ataStartCluster(). Também comparei os tempos de execução ao usar o parallel::makeCluster()versus sem paralelo, para ver se a computação paralela funciona como esperado, e de fato funciona.

Ao usar cl <- parallel::makeCluster(8, type = "PSOCK")o código paralelo, o tempo de execução é de 1,5 minuto, enquanto ao NÃO usar o código paralelo, o tempo de execução é de 3,2 minutos. O problema é que não tenho esse problema no meu outro laptop, que tem 4 GB de RAM e Windows 10, mas com a mesma versão do R e pacotes que estou usando neste laptop (consulte as informações da sessão abaixo).

O código que estou usando:

library(atakrig)
library(terra)
rpath <- system.file("extdata", package="atakrig")
aod3k <- rast(file.path(rpath, "MOD04_3K_A2017042.tif"))
aod10 <- rast(file.path(rpath, "MOD04_L2_A2017042.tif"))
aod3k.d <- discretizeRaster(aod3k, 1500)
aod10.d <- discretizeRaster(aod10, 1500)
grid.pred <- discretizeRaster(aod3k, 1500, type = "all")
aod3k.d$areaValues$value <- log(aod3k.d$areaValues$value)
aod10.d$areaValues$value <- log(aod10.d$areaValues$value)
## area-to-area Kriging ---# point-scale variogram from combined AOD-3k and AOD-10
aod.combine <- rbindDiscreteArea(x = aod3k.d, y = aod10.d)
vgm.ok_combine <- deconvPointVgm(aod.combine, model="Exp", ngroup=12, rd=0.75)
# point-scale cross-variogram
aod.list <- list(aod3k=aod3k.d, aod10=aod10.d)
aod.list <- list(aod3k=aod3k.d, aod10=aod10.d)
vgm.ck <- deconvPointVgmForCoKriging(aod.list, model="Exp", ngroup=12, rd=0.75,fixed.range = 9e4)
# prediction
cl <- parallel::makeCluster(8, type = "PSOCK")
pred.ataok <- ataKriging(aod10.d, grid.pred, vgm.ck$aod10, showProgress = TRUE, nopar = FALSE)
parallel::stopCluster(cl)

Informações da sessão:

R version 4.4.3 (2025-02-28 ucrt)
Platform: x86_64-w64-mingw32/x64
Running under: Windows 11 x64 (build 26100)

Matrix products: default


locale:
[1] LC_COLLATE=English_United States.utf8  LC_CTYPE=English_United States.utf8    LC_MONETARY=English_United States.utf8
[4] LC_NUMERIC=C                           LC_TIME=English_United States.utf8    


attached base packages:
[1] stats     graphics  grDevices utils     datasets  methods   base     

other attached packages:
[1] terra_1.8-42    atakrig_0.9.8.1

loaded via a namespace (and not attached):
 [1] DBI_1.2.3          KernSmooth_2.23-26 sf_1.0-20          doSNOW_1.0.20      zoo_1.8-13         spacetime_1.3-3    xts_0.14.1        
 [8] e1071_1.7-16       snow_0.4-4         sp_2.2-0           gstat_2.1-3        grid_4.4.3         classInt_0.4-11    foreach_1.5.2     
[15] FNN_1.1.4.1        intervals_0.15.5   compiler_4.4.3     codetools_0.2-20   Rcpp_1.0.14        rstudioapi_0.17.1  lattice_0.22-7    
[22] class_7.3-23       parallel_4.4.3     magrittr_2.0.3     tools_4.4.3        proxy_0.4-27       iterators_1.0.14   units_0.8-7 

EDITAR

Ao chamar o pacote foreach(ie, library(foreach)), fiz o código rodar com sucesso. Não sei por que e como isso ajudou.

<li>
        <a href="/home/articles/how_to_foo">How to foo</a>
    </li>

O PageSpeed ​​Insights diz que o elemento acima tem o maior elemento Contentful Paint de 3.220 ms

TTFB 600 ms
Load Delay 0 ms
Load Time 0 ms
Render Delay 2,620 ms

Alguém poderia dar uma dica sobre como investigar isso?

[Atualização 2025-04-10]

Segui a resposta e consegui reproduzir o atraso do LCP:

Já faz algum tempo que venho recuperando um único parâmetro de saída de procedimentos armazenados do Oracle no Groovy (para contexto, no NiFi) assim:

import groovy.sql.SQL

def inParemter = 'send this value to the stored proc'
def errorCount = 0
def conn = (create connection to DB, details are inconsequential here)
def sql = Sql.newInstance(conn)
sql.call('{call MY_SCHEMA.MY_STOREDPROC(?, ?)}', [inParameter, Sql.INTEGER], { ec -> errorCount = ec })
conn.close()

Minha pergunta é: qual é a sintaxe para recuperar mais de um parâmetro out? NÃO é esta:

sql.call('{call MY_SCHEMA.MY_STOREDPROC(?, ?, ?)}', [inParameter, Sql.INTEGER, Sql.VARCHAR], { ec -> errorCount = ec }, { es -> errorString = es})

Tentei outras coisas também. Pesquisei no Google, cheguei perto, mas ninguém tenta exatamente isso. Vi alguns exemplos que:

...{ ec, es -> ... }

Mas não tenho certeza de como formar a sintaxe para atribuir ece esa variáveis ​​Groovy.

Estou tentando descobrir como parar instantaneamente meu playbook quando os testes falham para uma ramificação específica, masterneste caso.

Este é meu código Ansible:

  - name: 'Run Tests'
    shell: testing.sh | tee "testing.log"
    register: testing

  - name: 'Show log'
    debug: 
      msg: "{{ testing.stdout_lines }}"

  - name: 'Set fact'
    set_fact:
       tests: >-
        {{
          testing.stdout_lines | join(' ') | regex_findall('(\d+)\s*failed') | map('int') | max == 0
        }}

No problema clássico de soma de subconjuntos, há um conjunto S e um alvo t, e o objetivo é encontrar um subconjunto de S cuja soma seja t. Esta variante tem uma solução em tempo pseudopolinomial.

Em uma variante do problema da soma de subconjuntos, o objetivo é encontrar todos os subconjuntos de S cuja soma é t. Esta variante não possui solução em tempo pseudopolinomial; veja as respostas aqui: Obtendo todos os subconjuntos do problema da soma de subconjuntos em Python usando Programação Dinâmica . Um dos comentários explica que, no pior caso, quando você tem N zeros e a soma necessária também é zero, você precisará gerar todos os 2^n - 1 subconjuntos - portanto, não é possível obter um resultado melhor que O(2^n).

E se não diferenciarmos entre dois itens do mesmo valor (de modo que, se dois conjuntos forem compostos de alguns itens com os mesmos valores, eles serão considerados o mesmo conjunto) --- qual é a complexidade de tempo de execução para gerar todos os diferentes subconjuntos com soma t?