1回答
我想要建立一个网站由吉突布的网页。为此，我想运行一个python脚本，该脚本从jinja生成html文件(我知道这可能很糟糕，但这是我所拥有的最好的)。
我的app.py是这个项目的根。对于工作人员，在设置python并安装库之后，我将：
- name: run python script
run: python3 app.py
但是，生成失败的消息如下：
'/home/runner/work/sty"rix560.github.io/styrix560.github.io/app.py'：python3:无法打开文件Errno 2没有这样的文件或目录
因此
浏览 4提问于2021-12-22得票数 1
回答已采纳
最近我在学习python，然后我意识到在python文档中有一个read1()。我想知道read()和read1()有什么不同？什么情况下我们应该使用read1()而不是read()？ https://docs.python.org/3/library/io.html#io.BufferedReader
浏览 51提问于2019-08-30得票数 9
回答已采纳
我在Python中有一个与qustion相关的简单打开文件。
做这样的事：
x = open('test.txt', 'rt')
print(x)
我得到了这个输出：
<_io.TextIOWrapper name='test.txt' mode='rt' encoding='cp1252'>
它是表示打开的文件的Python对象。这是一条相当大的溪流吗？Python中的流究竟代表了什么？
浏览 0提问于2020-01-11得票数 4
回答已采纳
1回答
我很难创建一个将发布/子源连接到大型查询接收器的dataflowRunner作业，方法是插入以下两个：
apache_beam.io.gcp.pubsub.PubSubSource
apache_beam.io.gcp.bigquery.BigQuerySink
在github上的beam/sdks/python/apache_beam/examples/streaming_wordcount.py ()示例中分别插入第59行和第74行。删除第61-70行并指定正确的pub/sub和bigquery参数之后，脚本在不构建管道的情况下运行时不会出错。
sidenote:脚本提到流管道支持在Pyt
浏览 0提问于2017-06-29得票数 0
回答已采纳
2回答
我想在插件中启动一个Jython解释器，然后在解释器中执行文件。
package com.jakob.jython;
import org.bukkit.plugin.java.JavaPlugin;
import org.python.core.PyObject;
import org.python.util.PythonInterpreter;
import java.io.IOException;
import java.io.InputStream;
import java.util.logging.Logger;
public class EmbeddedJython exte
浏览 1提问于2011-06-21得票数 2
回答已采纳
下面的流程显示在附图中。我正在接收来自另一个进程组的60个流文件，我希望它们通过使用ExecuteScript处理器执行的Python。
现在的问题是，我没有得到任何错误，但是没有一个流文件以"in“的形式传递，甚至可以遍历一个简单的脚本，其中它只是获取输入的流文件，删除它，然后创建一个新的具有旧流文件属性的流文件。队列中有一些记录，但它们根本没有进入执行脚本处理器。我只是使用这个简单的方法来测试我是否能够成功地运行python脚本。这是我的代码：
import java.io
from org.apache.commons.io import IOUtils
from ja
浏览 1提问于2020-07-28得票数 0
回答已采纳
我在使用tensorflow时遇到了问题。我想使用TFRecordWriter()，如下所示：
with tf.python_io.TFRecordWriter(testing_filename) as tfrecord_writer:
# do sth
但是我得到了一个错误：
AttributeError:模块“”tensorflow“”没有特性“”python_io“”
我正在使用tensorflow 1.2和python 3。
我如何解决这个问题？
谢谢。
浏览 70提问于2017-07-02得票数 6
我试图使用python中的ExecuteScript处理器从一个流文件生成多个流文件。
输出流文件依赖于配置的一个属性和输入流文件(xml内容)。
我尝试了很多事情，但我总是以错误结束，比如：
此流文件已标记为传输。
转移关系未指定
以下是最后一个版本：
from org.apache.commons.io import IOUtils
from java.nio.charset import StandardCharsets
from org.apache.nifi.processor.io import StreamCallback
import java.io
from
浏览 0提问于2019-03-21得票数 0
我已经测试了多个node包和教程，试图在node和python之间进行通信，但没有任何成功。下面是一个简单的节点应用程序流数据：
(可在找到)
const NATS = require('nats')
const SERVERS = [
'nats://nats1.polygon.io:30401',
'nats://nats2.polygon.io:30402',
'nats://nats3.polygon.io:30403'
]
// Connect to Polygon NATS cluster:
浏览 0提问于2017-08-09得票数 1
我试图在execute命令处理器中执行python代码，并尝试在代码中读取/写入流文件，例如，我必须使用某些库
从org.apache.commons.io导入IOUtils
从java.nio.charset导入StandardCharsets
从org.apache.nifi.processor.io导入StreamCallback
例如，在库中，但是我在executeStreamCommand中发现了错误，没有找到模块。有人知道原因吗？
浏览 0提问于2019-04-25得票数 0
1回答
尝试在GCP云函数中创建GCP数据流。我已经部署了一个简单的apache函数，它工作得很好，但是当我试图读取文件时会出现路径错误。当我使用参数-runner从本地运行时，与Dataflowrunner一样，相同的脚本运行，有人建议我必须执行pip安装apache-beamgcp。我已经在当地做过了，而且效果很好。如果我试图在GCP中安装它，它会在一段时间后进行会话超时。下面是我的密码。
#import print library
# This script will read all avro files on a path and print them
import logging
imp
浏览 11提问于2022-08-04得票数 1
回答已采纳
读取从gcs传输的csv文件3/13/2020时开始遇到错误。下载后已检查ai-platform上的文件权限 相关文档：https://www.tensorflow.org/api_docs/python/tf/io/gfile/GFile (看起来readable属性已被移除...) 命令： sh.gsutil('cp',GCS_PATH,raw_rating_path)
with tf.io.gfile.GFile(raw_rating_path) as f:
df = pd.read_csv(f) 已验证文件是否为本地文件，并具有以下权限： -rw-rw-rw-
浏览 41提问于2020-04-02得票数 0
使用2to3从Python2迁移到Python3时，尚未调整types.FileType的导入。 为了区分这两种情况，是否适合检查io.TextIOWrapper和io.StringIO的isinstance()？ 或者，有没有一种更现代的pythonic方式来解决这个问题？
浏览 8提问于2019-12-26得票数 1
回答已采纳
我正在尝试使用Python从GCP上的云函数执行数据流管道。在使用DataFlowRunner的笔记本服务器上测试代码。但是，当使用云函数调用管道时，我得到以下信息：
错误
Traceback (most recent call last): File "/env/local/lib/python3.7/site-packages/google/cloud/functions/worker.py",
line 346, in run_http_function result = _function_handler.invoke_user_function(flask.req
浏览 2提问于2020-03-10得票数 0
回答已采纳
我在外面找不到很多提到这个的信息。在Lua中，这些标准的io描述符设置是要缓冲的还是非缓冲的？如果需要，我可以从一种模式切换到另一种模式吗？
例如，在python中，它提供了类似于sys.stdin.detach的东西来使其不缓冲。
浏览 0提问于2013-08-30得票数 8
回答已采纳
我正在尝试使用gzip模块高效地读入和解析一个压缩的文本文件。此link建议使用io.BufferedReader包装gzip文件对象，如下所示： import gzip, io
gz = gzip.open(in_path, 'rb')
f = io.BufferedReader(gz)
for line in f.readlines():
# do stuff
gz.close() 要在Python3中做到这一点，我认为必须用mode='rb'调用gzip。因此，结果是line是一个二进制字符串。但是，我需要line是文本/as
浏览 67提问于2019-02-11得票数 3
回答已采纳
我做错了什么。我试图解析我的Github中的Excel文件，但是出现了一个错误：Unsupported format, or corrupt file: Expected BOF record; found b'\n\n\n\n\n\n<!。我在Spyder和Google的笔记本电脑上做了这样的管理，得到了同样悲惨的结果。我是吉顿的初学者，也许我的.xlsx做错了什么，它的读数不正确？
import pandas as pd
import requests as rq
import io
from io import BytesIO
put_k_ses = 'https
浏览 2提问于2021-10-11得票数 0
我想模拟一个流，所以我逐行地遍历一个文本文件，用time.sleep() of 1秒将这些行写入另一个文本文件。问题是，python没有在1秒后将每一行写到文件中，而是只有在达到260行左右时才会这样做。
我不认为线是重点，我认为更多的是关于每条线的大小，因为不同的线大小，我得到不同的等待时间/大小。有人知道为什么python3会这样做吗?我该如何解决呢？
我的代码：
import io
import time
with io.open('stream.txt', 'w', encoding="utf-8") as f, io.open(
浏览 1提问于2018-12-27得票数 1
回答已采纳
我试图从像object这样的字节中读取行。
下面是一个非常简单的例子。我知道可以用不同的方式来完成，但是保持这个流程(BytesIO -> BufferedIOBase -> TextIOWrapper)是很重要的。
import io
bytes_io = io.BytesIO(b"a\nb\nc")
buffered_io_base = io.BufferedIOBase(bytes_io)
text_io = io.TextIOWrapper(buffered_io_base)
for line in text_io:
print(line)
这将导致
浏览 0提问于2019-02-18得票数 0
回答已采纳
我试图使用subprocess.popen()，将a io.BytesIO() bytetream传输到一个单独的程序，但我不知道这是如何实现的，也不知道是否可能。文档和示例都是关于文本和换行符的。
当我想出这样的东西时：
import io
from subprocess import *
stream = io.BytesIO()
someStreamCreatingProcess(stream)
command = ['somecommand', 'some', 'arguments']
process = Popen(comman
浏览 7提问于2013-12-02得票数 15
回答已采纳
我已经设置了一个Dask集群，并且我很高兴地向它发送基本的Prefect流。现在，我想做一些更有趣的事情，在它上使用我的python库来获取一个定制的对接器映像，并在dask集群上执行流/任务。
我的假设是，我可以离开dask集群(调度程序和工作人员)，因为他们拥有自己的python环境(在检查了所有不同的消息传递库之后，到处都有匹配的版本)。也就是说，如果流是在我的自定义storage中执行的，我不需要将我的库添加到这些机器中。但是，要么我没有正确地设置存储，要么假设上述情况不安全。换句话说，在我的自定义库中对对象进行腌制时，Dask集群确实需要了解我的python库。假设我有一个名为dat
浏览 2提问于2020-06-21得票数 2
我正在尝试解析通过pyCurl检索到的HTML页面，但是pyCurl WRITEFUNCTION返回的页面是字节而不是字符串，所以我无法使用BeautifulSoup解析它。
有没有办法把io.BytesIO转换成io.StringIO？
或者，是否有其他方法可以解析HTML页面？
我使用的是Python 3.3.2。
浏览 0提问于2014-07-04得票数 35
回答已采纳
我使用的是python 2.7.2和pyserial2.6。在与包含除"\n“以外的字符的设备交谈时，使用pyserial.readline()的最佳方式是什么？指出，在python中，pyserial.readline()不再接受'eol=‘参数，但建议按如下方式使用循环: ser =serial.serial_for_url(’2.6+：//‘，io.TextIOWrapper ) sio = io.TextIOWrapper(io.BufferedRWPair(ser，ser))
然而，python 特别对这种方法提出了警告，称"BufferedRWPair不会尝
浏览 0提问于2012-10-04得票数 1
回答已采纳
我正试着用一款安卓应用来控制我的覆盆子pi。我正在使用websocket来做这件事。作为测试，我只想从app (client)向host (pi)发送一条输出消息，该消息将执行python脚本。我无法执行python脚本。下面是我的代码：
host.java
import java.net.ServerSocket;
import java.net.Socket;
import java.io.OutputStream;
import java.io.PrintStream;
import java.io.IOException;
public class host{
public stat
浏览 0提问于2017-04-22得票数 0
我正在尝试让解析MP3s的ID3v1标记格式。根据，它是一个固定的格式结构，位于一定的偏移量-但诀窍是，这个偏移量不是从文件开始计算，而是从末尾计算的。
下面是标记的基本.ksy大纲，我认为这是理所当然的，它不应该改变：
meta:
id: id3v1
types:
id3v1_tag:
seq:
- id: magic
contents: 'TAG'
- id: title
size: 30
- id: artist
size: 30
- id: album
浏览 11提问于2016-08-07得票数 4
回答已采纳
2回答
电火花卡夫卡流
、、、
我在试着让火花群正常工作。请注意它是由其他人设置的。我试图通过星火流来整合卡夫卡，但是每当我尝试使用PySpark时，我都会得到以下错误，即使没有使用火花流也是如此。
据我所知，Spark正在使用spark.driver.extraClassPath在spark-defaults.conf文件中向工作节点发送kafka流jar的位置，jar位于所有节点上的正确位置，包括主节点。
我发现一件奇怪的事情是，当/jar文件指示jar位于/usr/local/src时，节点似乎在寻找jar目录中的jar。
在进行更改后，我重置了所有节点，甚至删除了jar的引用，但是节点仍然在查找它。
Py4JJava
浏览 1提问于2016-12-01得票数 1
回答已采纳
我有一个在数据流中运行的。它是从PubSub读物和写到GCS。有时，在插入文件时，我会收到类似“_start_upload中的错误”之类的错误.“，它来自：
File "/usr/local/lib/python3.8/site-packages/apitools/base/py/base_api.py", line 603, in __ProcessHttpResponse raise exceptions.HttpError.FromResponse( RuntimeError: apitools.base.py.exceptions.HttpError: HttpErro
浏览 2提问于2021-06-14得票数 0
回答已采纳
我正在开发一个python程序，以像Google模板一样使用。
我正在做的是用BigQuery从PubSub编写数据：
pipeline_options.view_as(StandardOptions).streaming = True
p = beam.Pipeline(options=pipeline_options)
(p
# This is the source of the pipeline.
| 'Read from PubSub' >> beam.io.ReadFromPubSub('projects/.
浏览 0提问于2018-11-05得票数 0
回答已采纳
1回答
我一直在试图找出与python的uvloop和内置异步实现的不同之处。除了uvloop的基础是用c++编写的事实之外，在web中没有提到其他因素。我想知道影响他们之间的异步性的其他因素。
另外，请注意，这个由性能差异流和正常的异步io组成，不是从异步生成的，因此彼此依赖吗？
浏览 17提问于2021-12-12得票数 2
回答已采纳
从Google Cloud Composer访问GCS存储桶会导致类型错误： DEBUG:apache_beam.io.filesystem:Listing files in 'gs://BUCKET_NAME/FILENAME.2019-01-20'
DEBUG:apache_beam.io.filesystem:translate_pattern: 'gs://BUCKET_NAME/FILENAME.2019-01-20*' -> 'gs\\:\\/\\/BUCKET_NAME\\/FILENAME\\.2019\\-01\\-20[^/\
浏览 31提问于2019-01-21得票数 1
1回答
我试图从查看者抓取数据，并使用MediaFileUpload将其直接插入到Google表中，这样就不会下载任何文件并从内存中上传。下面的代码返回一个TypeError。任何帮助都将不胜感激。谢谢!
错误返回给我：
Traceback (most recent call last):
File "csvpython.py", line 96, in <module>
main()
File "csvpython.py", line 88, in main
media = MediaFileUpload(dataq, mimety
浏览 1提问于2018-02-09得票数 0
回答已采纳
2回答
目标是不断地从stdin中读取数据，并在Python2和Python3中执行utf8。
我尝试过以下几种解决方案：
我试过：
#!/usr/bin/env python
from __future__ import print_function, unicode_literals
import io
import sys
# Supports Python2 read from stdin and Python3 read from stdin.buffer
# https://stackoverflow.com/a/23932488/610569
user_input
浏览 6提问于2017-11-22得票数 3
回答已采纳
因此，我创建了一个StringIO对象，将我的字符串视为文件：
>>> a = 'Me, you and them\n'
>>> import io
>>> f = io.StringIO(a)
>>> f.read(1)
'M'
然后我继续关闭“文件”：
>>> f.close()
>>> f.closed
True
现在，当我再次尝试打开“文件”时，Python不允许我这样做：
>>> p = open(f)
Traceback (m
浏览 0提问于2015-05-28得票数 9
我有一个简单的数据流管道，并试图从云shell执行，
代码：
from __future__ import print_function
import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions
with beam.Pipeline(options=PipelineOptions()) as p:
lines = p | 'Read' >> beam.io.ReadFromText('test.csv')
li
浏览 0提问于2019-03-30得票数 0
回答已采纳
1回答
在python2中，我的测试方法中有这样的内容：
mock_file = MagicMock(spec=file)
我要搬到python3，我不知道如何做类似的模拟。我试过：
from io import IOBase
mock_file = MagicMock(spec=IOBase)
mock_file = create_autospec(IOBase)
我遗漏了什么？
浏览 0提问于2019-04-11得票数 2
回答已采纳
1回答
我需要从字符串生成的多个txt文件创建一个zip文件。 import zipfile
from io import StringIO
def zip_files(file_arr):
# file_arr is an array of [(fname, fbuffer), ...]
f = StringIO()
z = zipfile.ZipFile(f, 'w', zipfile.ZIP_DEFLATED)
for f in file_arr:
z.writestr(f[0], f[1])
z.close()
浏览 13提问于2020-09-02得票数 0
1回答
用数据流批量插入Bigquery
、、、、
我正在使用apache管道，我想用python批量插入bigquery。我的数据来自Pub/Sub，它是无限的。作为我研究的结果，带有触发器的GlobalWindows应该可以解决我的问题。我尝试了我的管道窗口，但它仍然流insertion.My管道代码如下：
p2 = (p | 'Read ' >> beam.io.ReadFromPubSub(subscription=subscription_path,
with_attributes=True,
timestamp_attribute=None,id_label=None)
|
浏览 0提问于2019-01-04得票数 4
我有个基本问题。我正在用node.js + socket.io编写开始代码，在该代码中，我使用python子进程并在它返回数据时触发操作，即：
io.sockets.on('connection',function(socket) {
socket.on('load_api_call', function() {
var pythonarray=['/Users/<omitting path>/test_return_sub_dict.py']
var child=spawn('/U
浏览 6提问于2014-05-04得票数 1
回答已采纳
我有一个使用gz从下载的HTTP文件。现在，我想读取包含在xlsx文件中的gz文件，并将其转换为DataFrame。我试过这个：
julia> using HTTP, XLSX, DataFrames, GZip
julia> file = HTTP.get("http://www.tsetmc.com/tsev2/excel/IntraDayPrice.aspx?i=35425587644337450&m=30")
julia> write("c:/users/shayan/desktop/file.xlsx.gz", file.
浏览 7提问于2022-08-31得票数 1
回答已采纳
尝试按照本教程制作一个wsgi服务器，但使用python3.5.2中的下面代码获得错误TypeError: initial_value must be str or None, not bytes。
import io
env['wsgi.input'] = io.StringIO(self.request_data)
我怎样才能解决这个问题。提前谢谢。
浏览 4提问于2016-09-28得票数 0
我有一个使用Pyshell.send将消息发送到Node.JS脚本的Python服务器
当Pyshell使用print返回消息时，Node.JS使用pyshell.on接收消息，然后读出返回的消息。
当使用第二条消息再次执行此操作时，系统崩溃并显示以下错误：
Error [ERR_STREAM_WRITE_AFTER_END]: write after end
at writeAfterEnd (_stream_writable.js:243:12)
at Socket.Writable.write (_stream_writable.js:291:5)
at Pyth
浏览 0提问于2020-06-01得票数 0
我使用版本的PyDev :0.12.1
我直接从tensorflow文档中复制示例代码，
但是找不到一个属性并返回它。
input_fn = tf.contrib.learn.io.numpy_input_fn({"x":x}, y, batch_size=4,
AttributeError: module 'tensorflow.contrib.learn.python.learn.learn_io' has no attribute 'numpy_input_fn'
试图重新下载pydev和tensorflow，但它们都没有工作。
源代码
浏览 3提问于2017-04-10得票数 0
回答已采纳
2回答
我试图以流的形式从C#运行Python，并使用StreamWriter和StreamReader反复在和流之间传递输入和输出。
我能读和写，，但显然只有一次，而不是多次。(这正是我所需要的。)希望有人能告诉我我做错了什么。
(我知道我可以通过读和写文件来做我需要做的事情。但是，如果可以的话，我想避免这种情况，因为使用流似乎更干净。)
这是我的C#代码：
using System;
using System.Diagnostics;
using System.IO;
public class Stream_Read_Write
{
public static void Main()
浏览 6提问于2014-11-12得票数 4
回答已采纳
我计划用executescript处理器编写python代码。由于这是我第一次，我发现很难开始。
基本上，我希望读取want文件(csv)，并进行一些操作并将其写入want文件。
有没有一种方法可以让我们预先编写代码，比如假设jupyter，然后在处理器中复制相同的代码？
此外，是否有编写代码的语法文档？
EXECUTESTREAMCOMMAND
import org.apache.commons.io.IOUtils
import java.io
import csv
# Get flowFile Session
flowFile = session.get()
# Open data
浏览 0提问于2019-06-03得票数 0
回答已采纳
我有以下Python 3脚本：
from sys import argv
script, filename = argv
txt = open(filename)
print(f"Here's your file {filename}:")
print(txt.read())
当我们使用内置函数open()时，我们打开文件并返回相应的文件对象。
我知道read()不是内置函数，而是文件对象的方法。
正如这里关于文件对象的Python中所述，
文件对象实际上有三类:原始二进制文件、缓冲二进制文件和文本文件。它们的接口在io模块中定义。
我真的很难理解一些关
浏览 0提问于2019-01-22得票数 0
回答已采纳
看来，名为io.py的模块(在我的一些包中)无法在PyCharm (2017.3.1Community)中调试--断点从未命中。重命名此模块解决了问题。
问题是:在python中不推荐命名一个模块io.py？
还是它只是一个PyCharm特性/ bug？
有什么已知的解决办法吗？
谢谢
浏览 1提问于2017-12-27得票数 2
3回答
当我这样做时，在本地一切都很好：
cat input | python mapper.py | sort | python reducer.py
但是，当我在上运行流Mapreduce作业时，作业没有成功完成。mapper.py部分地运行(我知道这是因为沿途写信给stderr )。映射程序被“断开管道”错误打断，在任务尝试失败后，我可以从syslog检索该错误：
java.io.IOException: Broken pipe
at java.io.FileOutputStream.writeBytes(Native Method)
at java.io.FileOutputS
浏览 1提问于2012-03-26得票数 9
回答已采纳
我正在尝试记录通过命令提示符传递的everything。这包括由python脚本启动的批处理脚本输出。
如果我像这样运行python文件
python logEverything.py >> logFile.txt
它给了我我想要的东西，在命令提示符中打印的所有内容都将被放入该文件中。
问题是它不再在命令提示符中显示任何内容。另外，我希望能够在程序中指定日志文件路径。
那么，是否有一种方法可以记录通过命令提示符传递的所有内容？兼容windows和Linux？
所以logEverything.py是这样的
import sys
def main():
import io
浏览 0提问于2019-06-25得票数 0
回答已采纳
我试图运行一个简单的beam脚本上的GCP数据流，以便应用一个科学工具包-学习模型的一些数据。数据需要在应用模型之前和之后进行处理。这就是textExtraction和translationDictionary的特点。我一直在获取错误AttributeError: module 'google.cloud' has no attribute 'storage' (下面是完整的堆栈跟踪)。如您所见，我尝试使用新的安装在一个新的虚拟环境中运行。知道怎么修吗？
下面我也给出了我的脚本。
predict_DF_class.py
import apache_beam as
浏览 12提问于2020-09-13得票数 0
回答已采纳
我正在编写一段代码来打开一个(可能是gzipped格式的)文本文件，该文件可以在Python2和Python3中工作。
如果我只有普通的文本文件(不是压缩的)，我可以这样做：
import io
for line in io.open(file_name, encoding='some_encoding'):
pass
如果我不关心解码(在python2/3中使用字符串/字节)
if file_name.endswith('.gz'):
file_obj = gzip.open(file_name)
else:
file_obj = op
浏览 1提问于2012-09-19得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
