Python - Страница 879

Когда я нажимаю кнопку «📝 Ariza qoldirish», ничего не происходит.
Я использую aiogram2.25.2.
@dp.message_handler(commands= )
async def exit_system(message: types.Message, state: FSMContext):
# await state.reset_state(with_data=True) # Holatni...

У меня есть файл .parquet, и я хотел бы использовать Python для быстрого и эффективного запроса этого файла по столбцу.
Например, у меня может быть имя столбца в этом файле .parquet, и я хочу получить первые (или все) строки с выбранным именем.
Как...

ищем что-то вроде этого:
Сохранить Dataframe в CSV непосредственно в s3 Python
API показывает эти аргументы:

но я не уверен, как преобразовать df в поток...

Подробнее здесь:

Я выполняю рекурсивный доступ к каталогам, структура папок которых выглядит примерно так:
-- папка1
-- папка1.1
-- папка 1.1.1
-- папка 1.1.1.1 (здесь находятся документы, и я хочу получить даты их изменения)
-- папка2
-- папка2.1
-- папка2.1.1
--...

Я использую набор данных из нескольких фреймов данных в качестве временного хранилища данных, доступного для сценариев использования Power BI и Python. Как я могу перегруппировать данные, используя поляры, во фреймы данных определенного размера?...

Я хотел бы прочитать файл паркета с полярами (0.19.19), сохраненный с помощью pandas (2.1.3).
test_df = pd.DataFrame({ a : })
test_df = test_df.a.astype( category )
test_df.to_parquet( test_df.parquet )

test_pl_df = pl.read_parquet( test_df.parquet...

У меня есть потоковые данные в формате JSON, которые я преобразую в кадр данных Polars, а затем записываю данные в виде паркета, разделенного на два столбца. Я заметил, что если новая запись имеет тот же раздел, то вместо записи дополнительного...

У меня на s3 многосекционный паркет. Каждый раздел содержит несколько файлов паркета. Приведенный ниже код ограничивается одним разделом, который может содержать около 30 файлов паркета. Когда я использую scan_parquet по адресу s3, который включает...

Мне интересно, почему я наблюдаю такую ​​низкую производительность при написании LazyFrame с использованием PartitionByKey для S3 по сравнению с другими методами. Вот простой тестовый скрипт, который записывает случайные данные на диск и в S3:...

Следуя документации по чтению из облачного хранилища, я создал приведенный ниже скрипт, который не работает.
import boto3
import polars as pl
import os

session = boto3.Session(profile_name=os.environ )
credentials = session.get_credentials()...

Я хотел бы прочитать разделенный файл паркета в фрейм данных Polars.
В Spark это просто:
df = spark.read.parquet( /my/path )

В документации Polars сказано, что это должно работать так же:
df = pl.read_parquet( /my/path )

Но выдает ошибку:...

Имея более 1000 файлов s3 в секционированном пути, вы хотите прочитать все файлы. используя Polars, потому что он быстрее по сравнению с Pandas

s3://bucket_name/rs_tables/name='part1'/key='abc'/date=''/part1_0000.parquet

Сканирование этих файлов...

Начиная с этого фрейма данных:
import polars as pl

df_1 = pl.DataFrame({
'name': ,
'index': ,
'limit': ,
'price':
})

Мне нужно добавить новый столбец («min_index»), чтобы указать, при каком индексе (больше текущего) цена равна или превышает...

Коротко говоря, мне нужно обработать 100 гигабайт журналов в странном формате, а затем провести некоторый анализ результатов.
Выбрал CL в качестве своего инструмента, потому что я уже «комфортно» с ним работаю, несмотря на то, что раньше не...

Меня озадачивает то, что при запуске
class Cat(pydantic.BaseModel):
name: str
age: int

cats =
df = pl.DataFrame({ cats : cats})
df = df.with_columns(pl.lit(0).alias( acq_num ))

def wrap(batch):
return Cat(name= c , age=3)

df = df.group_by(...

У меня есть кадр (события), который я хочу объединить с другим кадром (fr), присоединившись по дате и символу. Даты не обязательно совпадают. Дата в событиях будет совпадать с первым появлением только в ту же или более позднюю дату во fr, поэтому,...

Предположим, у меня есть Polars df:
import polars as pl

df = pl.DataFrame({'name': ,
'found': ,
'found_in_iteration': })

(Этот df был сгенерирован за две итерации, и для a некоторые данные были найдены в первой, но не во второй, а для b данные не...

Есть ли способ сделать то же самое, что и параметр «как» из pl.concat, но с помощью read_parquet?

Подробнее здесь:

Рассмотрим следующий пример:
import polars as pl

df = pl.DataFrame(
[
pl.Series(
name , , dtype=pl.Enum( )
),
pl.Series( month , , dtype=pl.Int8()),
pl.Series(
category , , dtype=pl.Enum( )
),
]
)
print(df)

shape: (4, 3)...

У меня есть фрагмент панды ниже, который я хочу преобразовать в полярные, чтобы попробовать. Ожидаемый результат для полярных полей такой же, как и для панд, но не получается, так как совокупная сумма отсутствует. Как добиться аналогичного...

Привет, я хочу определить полярную схему.
Она отлично работает без формата даты и времени.
Однако с pl.Datetime не получается.
import polars as pl

testing_schema: pl.Schema = pl.Schema(
{
date : pl.Datetime,
some_int : pl.Int64,
some_str :...

Я выполнил следующее в блокноте Jupyter и был разочарован тем, что аналогичный код Pandas работает быстрее. Надеюсь, кто-нибудь сможет продемонстрировать более разумный подход в Polars.
ВЕРСИЯ POLARS
def cleanse_text(sentence):
RIGHT_QUOTE = r...

Какой предпочтительный способ назначить/добавить новый столбец в кадр данных Polars в .select() или .with_columns()?

Существуют ли какие-либо различия между приведенными ниже назначениями столбцов с использованием .alias() или знака =?
import...

У меня есть следующий фрейм данных:
import polars as pl

df = pl.DataFrame({
'ID': ,
'YEAR':
})
shape: (7, 2)
┌─────┬──────┐
│ ID ┆ YEAR │
│ --- ┆ --- │
│ i64 ┆ i64 │
╞═════╪══════╡
│ 1 ┆ 2025 │
│ 1 ┆ 2025 │
│ 5 ┆ 2023 │
│ 5 ┆ 2024 │
│ 7 ┆ 2020 │...

Пример df:
import polars as pl
import numpy as np
df = pl.DataFrame(
{
nrs : ,
names : ,
random : np.random.rand(5),
A : ,
}
)

Я хочу заменить столбец случайным образом. До сих пор я делал
new = np.arange(5)
df.replace('random',...