小编Yih*_*Bao的帖子

嗨，我是气流的新手并尝试安装它。我可以成功安装气流，但是当我做一个时airflow initdb，错误是：

(airflow_virtualenv) C02CF6JRMD6R:bin ybao$ airflow initdb

    Traceback (most recent call last):   File "/Users/ybao/airflow_virtualenv/bin/airflow", line 26, in <module>
        from airflow.bin.cli import CLIFactory   File "/Users/ybao/airflow_virtualenv/lib/python2.7/site-packages/airflow/bin/cli.py", line 82, in <module>
        from airflow.www.app import (cached_app, create_app)   File "/Users/ybao/airflow_virtualenv/lib/python2.7/site-packages/airflow/www/app.py", line 42, in <module>
        from airflow.www.blueprints import routes   File "/Users/ybao/airflow_virtualenv/lib/python2.7/site-packages/airflow/www/blueprints.py", line 25, in <module>
        from airflow.www import utils as wwwutils   File "/Users/ybao/airflow_virtualenv/lib/python2.7/site-packages/airflow/www/utils.py", line 40, in <module>
        import flask_admin.contrib.sqla.filters as sqlafilters   File "/Users/ybao/airflow_virtualenv/lib/python2.7/site-packages/flask_admin/contrib/sqla/__init__.py", line 2, in <module>
        from .view import ModelView   File "/Users/ybao/airflow_virtualenv/lib/python2.7/site-packages/flask_admin/contrib/sqla/view.py", line …

我想在模型上使用多处理来使用数据框作为输入来获得预测.我有以下代码:

def perform_model_predictions(model, dataFrame, cores=4): 
    try:
        with Pool(processes=cores) as pool:
            result = pool.map(model.predict, dataFrame)
            return result
        # return model.predict(dataFrame)
    except AttributeError:
        logging.error("AttributeError occurred", exc_info=True)

我得到的错误是:

raise TypeError("sparse matrix length is ambiguous; use getnnz()"
TypeError: sparse matrix length is ambiguous; use getnnz() or shape[0]

我认为问题在于我将数据帧作为pool.map函数的第二个参数传递.任何建议或帮助将不胜感激.

我正在使用 writexl 包将两个数据帧保存到 R闪亮的一个 csv 文件中。

这是我的代码的一部分：

library(writexl)
server <- function(input,output){
    filename = function(){
              paste('data.csv')
            },
    content = function(file){
    df1  <- ...
    df2 <- ...
    write_xlsx(list(df1,df2), file) 
        }
      )

此代码适用于我，但您知道如何为 df1 和 df2 指定自定义工作表名称吗？我不想更改包，只想使用“write_xlsx”，而不是“write.xlsx”

我正在尝试创建一个闪亮的应用程序，它可以从数据库下载文件，但查询时间很长，所以我想让用户知道，在按下按钮后，网络浏览器显示“正在加载给用户”，然后下载完成后，“正在加载”将被隐藏。

这是我的代码：

if (interactive()) {
  
  library(shiny)
  library(shinyWidgets)
  
  ui <- fluidPage(
    downloadBttn(
      outputId = "downloadData",
      style = "bordered",
      color = "primary"
    )
  )
  
  server <- function(input, output, session) {
    data_xi <- data.frame(s = c(1:3),r = c(4:6), x =c(19:21))
    
    observeEvent(input$downloadData, {
      showModal(modalDialog("Loading", footer=NULL))
      
      filename = function() {
        paste('data-', Sys.Date(), '.csv', sep='')
      }
      
      content = function(file) {
        write_xlsx(data_xi,file)
      }
      
      removeModal()
    })
  }
  shinyApp(ui, server)
  
}