fix

tasks/zinoveva-ad/lab_2/.gitignore

@@ -1,454 +0,0 @@
-## Ignore Visual Studio temporary files, build results, and
-## files generated by popular Visual Studio add-ons.
-##
-## Get latest from https://github.com/github/gitignore/blob/master/VisualStudio.gitignore
-
-# User-specific files
-*.rsuser
-*.suo
-*.user
-*.userosscache
-*.sln.docstates
-
-# User-specific files (MonoDevelop/Xamarin Studio)
-*.userprefs
-
-# Mono auto generated files
-mono_crash.*
-
-# Build results
-[Dd]ebug/
-[Dd]ebugPublic/
-[Rr]elease/
-[Rr]eleases/
-x64/
-x86/
-[Ww][Ii][Nn]32/
-[Aa][Rr][Mm]/
-[Aa][Rr][Mm]64/
-bld/
-[Bb]in/
-[Oo]bj/
-[Ll]og/
-[Ll]ogs/
-
-# Visual Studio 2015/2017 cache/options directory
-.vs/
-# Uncomment if you have tasks that create the project's static files in wwwroot
-#wwwroot/
-
-# Visual Studio 2017 auto generated files
-Generated\ Files/
-
-# MSTest test Results
-[Tt]est[Rr]esult*/
-[Bb]uild[Ll]og.*
-
-# NUnit
-*.VisualState.xml
-TestResult.xml
-nunit-*.xml
-
-# Build Results of an ATL Project
-[Dd]ebugPS/
-[Rr]eleasePS/
-dlldata.c
-
-# Benchmark Results
-BenchmarkDotNet.Artifacts/
-
-# .NET Core
-project.lock.json
-project.fragment.lock.json
-artifacts/
-
-# Tye
-.tye/
-
-# ASP.NET Scaffolding
-ScaffoldingReadMe.txt
-
-# StyleCop
-StyleCopReport.xml
-
-# Files built by Visual Studio
-*_i.c
-*_p.c
-*_h.h
-*.ilk
-*.meta
-*.obj
-*.iobj
-*.pch
-*.pdb
-*.ipdb
-*.pgc
-*.pgd
-*.rsp
-*.sbr
-*.tlb
-*.tli
-*.tlh
-*.tmp
-*.tmp_proj
-*_wpftmp.csproj
-*.log
-*.vspscc
-*.vssscc
-.builds
-*.pidb
-*.svclog
-*.scc
-
-# Chutzpah Test files
-_Chutzpah*
-
-# Visual C++ cache files
-ipch/
-*.aps
-*.ncb
-*.opendb
-*.opensdf
-*.sdf
-*.cachefile
-*.VC.db
-*.VC.VC.opendb
-
-# Visual Studio profiler
-*.psess
-*.vsp
-*.vspx
-*.sap
-
-# Visual Studio Trace Files
-*.e2e
-
-# TFS 2012 Local Workspace
-$tf/
-
-# Guidance Automation Toolkit
-*.gpState
-
-# ReSharper is a .NET coding add-in
-_ReSharper*/
-*.[Rr]e[Ss]harper
-*.DotSettings.user
-
-# TeamCity is a build add-in
-_TeamCity*
-
-# DotCover is a Code Coverage Tool
-*.dotCover
-
-# AxoCover is a Code Coverage Tool
-.axoCover/*
-!.axoCover/settings.json
-
-# Coverlet is a free, cross platform Code Coverage Tool
-coverage*.json
-coverage*.xml
-coverage*.info
-
-# Visual Studio code coverage results
-*.coverage
-*.coveragexml
-
-# NCrunch
-_NCrunch_*
-.*crunch*.local.xml
-nCrunchTemp_*
-
-# MightyMoose
-*.mm.*
-AutoTest.Net/
-
-# Web workbench (sass)
-.sass-cache/
-
-# Installshield output folder
-[Ee]xpress/
-
-# DocProject is a documentation generator add-in
-DocProject/buildhelp/
-DocProject/Help/*.HxT
-DocProject/Help/*.HxC
-DocProject/Help/*.hhc
-DocProject/Help/*.hhk
-DocProject/Help/*.hhp
-DocProject/Help/Html2
-DocProject/Help/html
-
-# Click-Once directory
-publish/
-
-# Publish Web Output
-*.[Pp]ublish.xml
-*.azurePubxml
-# Note: Comment the next line if you want to checkin your web deploy settings,
-# but database connection strings (with potential passwords) will be unencrypted
-*.pubxml
-*.publishproj
-
-# Microsoft Azure Web App publish settings. Comment the next line if you want to
-# checkin your Azure Web App publish settings, but sensitive information contained
-# in these scripts will be unencrypted
-PublishScripts/
-
-# NuGet Packages
-*.nupkg
-# NuGet Symbol Packages
-*.snupkg
-# The packages folder can be ignored because of Package Restore
-**/[Pp]ackages/*
-# except build/, which is used as an MSBuild target.
-!**/[Pp]ackages/build/
-# Uncomment if necessary however generally it will be regenerated when needed
-#!**/[Pp]ackages/repositories.config
-# NuGet v3's project.json files produces more ignorable files
-*.nuget.props
-*.nuget.targets
-
-# Microsoft Azure Build Output
-csx/
-*.build.csdef
-
-# Microsoft Azure Emulator
-ecf/
-rcf/
-
-# Windows Store app package directories and files
-AppPackages/
-BundleArtifacts/
-Package.StoreAssociation.xml
-_pkginfo.txt
-*.appx
-*.appxbundle
-*.appxupload
-
-# Visual Studio cache files
-# files ending in .cache can be ignored
-*.[Cc]ache
-# but keep track of directories ending in .cache
-!?*.[Cc]ache/
-
-# Others
-ClientBin/
-~$*
-*~
-*.dbmdl
-*.dbproj.schemaview
-*.jfm
-*.pfx
-*.publishsettings
-orleans.codegen.cs
-
-# Including strong name files can present a security risk
-# (https://github.com/github/gitignore/pull/2483#issue-259490424)
-#*.snk
-
-# Since there are multiple workflows, uncomment next line to ignore bower_components
-# (https://github.com/github/gitignore/pull/1529#issuecomment-104372622)
-#bower_components/
-
-# RIA/Silverlight projects
-Generated_Code/
-
-# Backup & report files from converting an old project file
-# to a newer Visual Studio version. Backup files are not needed,
-# because we have git ;-)
-_UpgradeReport_Files/
-Backup*/
-UpgradeLog*.XML
-UpgradeLog*.htm
-ServiceFabricBackup/
-*.rptproj.bak
-
-# SQL Server files
-*.mdf
-*.ldf
-*.ndf
-
-# Business Intelligence projects
-*.rdl.data
-*.bim.layout
-*.bim_*.settings
-*.rptproj.rsuser
-*- [Bb]ackup.rdl
-*- [Bb]ackup ([0-9]).rdl
-*- [Bb]ackup ([0-9][0-9]).rdl
-
-# Microsoft Fakes
-FakesAssemblies/
-
-# GhostDoc plugin setting file
-*.GhostDoc.xml
-
-# Node.js Tools for Visual Studio
-.ntvs_analysis.dat
-node_modules/
-
-# Visual Studio 6 build log
-*.plg
-
-# Visual Studio 6 workspace options file
-*.opt
-
-# Visual Studio 6 auto-generated workspace file (contains which files were open etc.)
-*.vbw
-
-# Visual Studio LightSwitch build output
-**/*.HTMLClient/GeneratedArtifacts
-**/*.DesktopClient/GeneratedArtifacts
-**/*.DesktopClient/ModelManifest.xml
-**/*.Server/GeneratedArtifacts
-**/*.Server/ModelManifest.xml
-_Pvt_Extensions
-
-# Paket dependency manager
-.paket/paket.exe
-paket-files/
-
-# FAKE - F# Make
-.fake/
-
-# CodeRush personal settings
-.cr/personal
-
-# Python Tools for Visual Studio (PTVS)
-__pycache__/
-*.pyc
-
-# Cake - Uncomment if you are using it
-# tools/**
-# !tools/packages.config
-
-# Tabs Studio
-*.tss
-
-# Telerik's JustMock configuration file
-*.jmconfig
-
-# BizTalk build output
-*.btp.cs
-*.btm.cs
-*.odx.cs
-*.xsd.cs
-
-# OpenCover UI analysis results
-OpenCover/
-
-# Azure Stream Analytics local run output
-ASALocalRun/
-
-# MSBuild Binary and Structured Log
-*.binlog
-
-# NVidia Nsight GPU debugger configuration file
-*.nvuser
-
-# MFractors (Xamarin productivity tool) working folder
-.mfractor/
-
-# Local History for Visual Studio
-.localhistory/
-
-# BeatPulse healthcheck temp database
-healthchecksdb
-
-# Backup folder for Package Reference Convert tool in Visual Studio 2017
-MigrationBackup/
-
-# Ionide (cross platform F# VS Code tools) working folder
-.ionide/
-
-# Fody - auto-generated XML schema
-FodyWeavers.xsd
-
-##
-## Visual studio for Mac
-##
-
-
-# globs
-Makefile.in
-*.userprefs
-*.usertasks
-config.make
-config.status
-aclocal.m4
-install-sh
-autom4te.cache/
-*.tar.gz
-tarballs/
-test-results/
-
-# Mac bundle stuff
-*.dmg
-*.app
-
-# content below from: https://github.com/github/gitignore/blob/master/Global/macOS.gitignore
-# General
-.DS_Store
-.AppleDouble
-.LSOverride
-
-# Icon must end with two \r
-Icon
-
-
-# Thumbnails
-._*
-
-# Files that might appear in the root of a volume
-.DocumentRevisions-V100
-.fseventsd
-.Spotlight-V100
-.TemporaryItems
-.Trashes
-.VolumeIcon.icns
-.com.apple.timemachine.donotpresent
-
-# Directories potentially created on remote AFP share
-.AppleDB
-.AppleDesktop
-Network Trash Folder
-Temporary Items
-.apdisk
-
-# content below from: https://github.com/github/gitignore/blob/master/Global/Windows.gitignore
-# Windows thumbnail cache files
-Thumbs.db
-ehthumbs.db
-ehthumbs_vista.db
-
-# Dump file
-*.stackdump
-
-# Folder config file
-[Dd]esktop.ini
-
-# Recycle Bin used on file shares
-$RECYCLE.BIN/
-
-# Windows Installer files
-*.cab
-*.msi
-*.msix
-*.msm
-*.msp
-
-# Windows shortcuts
-*.lnk
-
-# JetBrains Rider
-.idea/
-*.sln.iml
-
-##
-## Visual Studio Code
-##
-.vscode/*
-!.vscode/settings.json
-!.vscode/tasks.json
-!.vscode/launch.json
-!.vscode/extensions.json

tasks/zinoveva-ad/lab_2/README.md

@@ -1,85 +0,0 @@
-# Отчёт по лабораторной работе №2
-
-Выполнил: студентка гр. ИСЭбд-41, Зиновьева Анна.
-
-Вариант программы 1: 4. Формирует файл `/var/result/data.txt` так, что каждая строка файла - количество символов в именах файлов из каталога `/var/data`.
-
-Вариант программы 2: 3. Ищет набольшее число из файла `/var/data/data.txt` и сохраняет количество таких чисел из последовательности в `/var/result/result.txt`.
-
-## Создание приложений
-
-Создадим 2 приложения.
-Был выбран язык C# и технология .NET 7.
-
-Для создания обычных консольных приложений воспользуемся командами:
-
-```sh
-dotnet new console -o worker-1
-dotnet new console -o worker-2
-```
-
-Согласно варианту, программа 1 должна брать все файлы из папки `/var/data`, считывать длину их названия, найти минимальное и переложить его в папку `/var/result`.
-
-[Исходный текст программы worker-1](worker-1/Program.cs)
-
-Согласно варианту программа 2 должна брать строки из папки `/var/data/` с скопированным файлом, пытаться привести их к числам, затем найти минимальное из них.
-Далее найти количество вхождений этого числа и результат записать в файл `/var/result/result.txt`.
-
-[Исходный текст программы worker-2](worker-2/Program.cs)
-
-Дополнительно создан файл [.gitignore](.gitignore) для того, чтобы не закоммитить в git ничего лишнего.
-
-## Настройка окружения
-
-Для связи двух приложений воспользуемся следующей схемой:
-
-1. Каталог `./data` должен быть примонтирован в каталог `/var/data` для программы 1.
-   Оттуда будут браться исходные данные.
-2. Каталог `./result-1` должен быть примонтирован в каталог `/var/result` для программы 2.
-   Туда будут складываться промежуточные данные.
-3. Каталог `./result-1` также должен быть примонтирован в каталог `/var/data` для программы 2.
-   Оттуда будут браться промежуточные результаты.
-4. Каталог `./result` должен быть примонтирован в каталог `/var/result` для программы 2.
-   Туда будут складывать результаты финальной обработки.
-
-Для каждой программы были созданы файлы Dockerfile ([программа 1](worker-1/Dockerfile), [программа 2](worker-2/Dockerfile)) с подробным описанием процесса сборки.
-
-Был создан файл [docker-compose.yml](docker-compose.yml), в котором указан манифест для запуска распределённого приложения.
-
-
-## Сборка и запуск
-
-1. В каталог `./data` помещены 3 файла с различной длиной названия и содержимым.
-
-![](photo_2023-10-10_16-25-51.jpg)
-
-На выходе программа должна записать 7 8 8.
-
-![](Screenshot_2.jpg)
-
-2. Теперь, обрабатывая этот файл:
-
-![](Screenshot_3.jpg)
-
-На выходе программа должна записать число 2 в `./result` так как в файле c названием data.txt максимальное число = 8, которое встречается 2 раза.
-
-![](Screenshot_4.jpg)
-
-Для запуска приложения необходимо ввести команду `docker compose up --build`.
-Результат запуска после сборки:
-
-```
-[+] Running 2/0
- ✔ Container lab_2-worker-1-1  Created                                                                                                                                                               0.0s
- ✔ Container lab_2-worker-2-1  Created                                                                                                                                                               0.0s
-Attaching to lab_2-worker-1-1, lab_2-worker-2-1
-lab_2-worker-1-1  | Файл успешно создан: ../var/result/data.txt
-lab_2-worker-2-1  | The maximum number is: 8
-lab_2-worker-2-1  | The count of maximum numbers is: 2
-lab_2-worker-1-1 exited with code 0
-lab_2-worker-2-1 exited with code 0
-```
-
-В результате в каталоге `./result` создался файл `result.txt` с содержимым `7 8 8`, что соответствует входным данным.
-
-Изменение значений в файлах из каталога `./data` также изменяет содержимое в файлах из каталогов `./result-1` и `./result`.

tasks/zinoveva-ad/lab_2/data/data.txt

@@ -1,12 +0,0 @@
-5
-7
-3
-7
-5
-8
-8
-9
-9
-5
-2
-1

tasks/zinoveva-ad/lab_2/docker-compose.yml

@@ -1,18 +0,0 @@
-version: "3.1"
-services:
-  worker-1:
-    build: ./worker-1
-    volumes:
-      # Монтирует локальную папку data к папке data в контейнере.
-      - ./data:/var/data
-      # Монтирует локальную папку result-1 к папке result в контейнере.
-      - ./result-1:/var/result
-  worker-2:
-    build: ./worker-2
-    volumes:
-      # Монтирует локальную папку result-1 к папке data в контейнере.
-      - ./result-1:/var/data
-      - ./result:/var/result
-    # Зависимость от первого приложения.
-    depends_on:
-      - worker-1

tasks/zinoveva-ad/lab_2/lab_2.sln

@@ -1,48 +0,0 @@
-
-Microsoft Visual Studio Solution File, Format Version 12.00
-# Visual Studio Version 16
-VisualStudioVersion = 16.0.30114.105
-MinimumVisualStudioVersion = 10.0.40219.1
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "worker-1", "worker-1\worker-1.csproj", "{634E1073-C536-49F1-92E2-48812E9724D4}"
-EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "worker-2", "worker-2\worker-2.csproj", "{CD71CC0E-6A85-4AC9-B8CE-47910331C868}"
-EndProject
-Global
-	GlobalSection(SolutionConfigurationPlatforms) = preSolution
-		Debug|Any CPU = Debug|Any CPU
-		Debug|x64 = Debug|x64
-		Debug|x86 = Debug|x86
-		Release|Any CPU = Release|Any CPU
-		Release|x64 = Release|x64
-		Release|x86 = Release|x86
-	EndGlobalSection
-	GlobalSection(SolutionProperties) = preSolution
-		HideSolutionNode = FALSE
-	EndGlobalSection
-	GlobalSection(ProjectConfigurationPlatforms) = postSolution
-		{634E1073-C536-49F1-92E2-48812E9724D4}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{634E1073-C536-49F1-92E2-48812E9724D4}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{634E1073-C536-49F1-92E2-48812E9724D4}.Debug|x64.ActiveCfg = Debug|Any CPU
-		{634E1073-C536-49F1-92E2-48812E9724D4}.Debug|x64.Build.0 = Debug|Any CPU
-		{634E1073-C536-49F1-92E2-48812E9724D4}.Debug|x86.ActiveCfg = Debug|Any CPU
-		{634E1073-C536-49F1-92E2-48812E9724D4}.Debug|x86.Build.0 = Debug|Any CPU
-		{634E1073-C536-49F1-92E2-48812E9724D4}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{634E1073-C536-49F1-92E2-48812E9724D4}.Release|Any CPU.Build.0 = Release|Any CPU
-		{634E1073-C536-49F1-92E2-48812E9724D4}.Release|x64.ActiveCfg = Release|Any CPU
-		{634E1073-C536-49F1-92E2-48812E9724D4}.Release|x64.Build.0 = Release|Any CPU
-		{634E1073-C536-49F1-92E2-48812E9724D4}.Release|x86.ActiveCfg = Release|Any CPU
-		{634E1073-C536-49F1-92E2-48812E9724D4}.Release|x86.Build.0 = Release|Any CPU
-		{CD71CC0E-6A85-4AC9-B8CE-47910331C868}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{CD71CC0E-6A85-4AC9-B8CE-47910331C868}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{CD71CC0E-6A85-4AC9-B8CE-47910331C868}.Debug|x64.ActiveCfg = Debug|Any CPU
-		{CD71CC0E-6A85-4AC9-B8CE-47910331C868}.Debug|x64.Build.0 = Debug|Any CPU
-		{CD71CC0E-6A85-4AC9-B8CE-47910331C868}.Debug|x86.ActiveCfg = Debug|Any CPU
-		{CD71CC0E-6A85-4AC9-B8CE-47910331C868}.Debug|x86.Build.0 = Debug|Any CPU
-		{CD71CC0E-6A85-4AC9-B8CE-47910331C868}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{CD71CC0E-6A85-4AC9-B8CE-47910331C868}.Release|Any CPU.Build.0 = Release|Any CPU
-		{CD71CC0E-6A85-4AC9-B8CE-47910331C868}.Release|x64.ActiveCfg = Release|Any CPU
-		{CD71CC0E-6A85-4AC9-B8CE-47910331C868}.Release|x64.Build.0 = Release|Any CPU
-		{CD71CC0E-6A85-4AC9-B8CE-47910331C868}.Release|x86.ActiveCfg = Release|Any CPU
-		{CD71CC0E-6A85-4AC9-B8CE-47910331C868}.Release|x86.Build.0 = Release|Any CPU
-	EndGlobalSection
-EndGlobal

tasks/zinoveva-ad/lab_2/result-1/data.txt

@@ -1,3 +0,0 @@
-7
-8
-8

tasks/zinoveva-ad/lab_2/result/result.txt

@@ -1 +0,0 @@
-2

tasks/zinoveva-ad/lab_2/worker-1/Dockerfile

@@ -1,18 +0,0 @@
-# Задаем базовый образ на .net
-FROM mcr.microsoft.com/dotnet/sdk:5.0 AS build-env
-# Задаем рабочую директорию
-WORKDIR /src
-
-
-# Копируем файлы и папки в каталог в контейнер
-COPY . ./
-# Создаем образы и устанавливаем данные пакеты в контейнер
-RUN dotnet restore
-COPY . .
-RUN dotnet publish -c Release -o /publish
-
-FROM mcr.microsoft.com/dotnet/aspnet:5.0 
-WORKDIR /publish
-COPY --from=build-env /publish .
-# Вызываем приложение во время выполнения контейнера
-ENTRYPOINT ["dotnet", "worker-1.dll"]

tasks/zinoveva-ad/lab_2/worker-1/Program.cs

@@ -1,27 +0,0 @@
-using System;
-using System.IO;
-
-var dir = new DirectoryInfo("/var/data");
-
-var files = dir.GetFiles();
-
-//var quantity_files = dir.GetFiles().Length;
-
-string resultFilePath = "/var/result/data.txt";
-try
-{
-    // Создаем новый файл или перезаписываем существующий
-    using (StreamWriter writer = new StreamWriter(resultFilePath, false))
-    {
-        foreach (var file in files)
-        {
-            // Записываем в файл количество символов в имени каждого файла
-            writer.WriteLine(file.Name.Length);
-        }
-    }
-    Console.WriteLine("Файл успешно создан: " + resultFilePath);
-}
-catch (Exception ex)
-{
-    Console.WriteLine("Произошла ошибка: " + ex.Message);
-}

tasks/zinoveva-ad/lab_2/worker-1/worker-1.csproj

@@ -1,9 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-  <PropertyGroup>
-    <OutputType>Exe</OutputType>
-    <TargetFramework>net5.0</TargetFramework>
-    <RootNamespace>worker_1</RootNamespace>
-  </PropertyGroup>
-
-</Project>

tasks/zinoveva-ad/lab_2/worker-2/Dockerfile

@@ -1,18 +0,0 @@
-# Задаем базовый образ на .net
-FROM mcr.microsoft.com/dotnet/sdk:5.0 AS build-env
-# Задаем рабочую директорию
-WORKDIR /src
-
-
-# Копируем файлы и папки в каталог в контейнер
-COPY . ./
-# Создаем образы и устанавливаем данные пакеты в контейнер
-RUN dotnet restore
-COPY . .
-RUN dotnet publish -c Release -o /publish
-
-FROM mcr.microsoft.com/dotnet/aspnet:5.0
-WORKDIR /publish
-COPY --from=build-env /publish .
-# Вызываем приложение во время выполнения контейнера
-ENTRYPOINT ["dotnet", "worker-2.dll"]

tasks/zinoveva-ad/lab_2/worker-2/Program.cs

@@ -1,58 +0,0 @@
-using System;
-using System.IO;
-
-string filePath = "/var/data/data.txt";
-string resultPath = "/var/result/result.txt";
-
-// Считываем числа из файла
-int[] numbers = ReadNumbersFromFile(filePath);
-
-// Ищем наибольшее число
-int maxNumber = FindMaxNumber(numbers);
-
-// Считаем количество таких чисел
- int count = CountNumbers(numbers, maxNumber);
-
-// Сохраняем результат в файл
- SaveCountToFile(resultPath, count);
-        
-Console.WriteLine($"Максимальное число: {maxNumber}");
-Console.WriteLine($"Количество макисмальных чисел: {count}");
-
- static int[] ReadNumbersFromFile(string filePath)
-    {
-        string[] lines = File.ReadAllLines(filePath);
-        int[] numbers = Array.ConvertAll(lines, int.Parse);
-        return numbers;
-    }
-
-    static int FindMaxNumber(int[] numbers)
-    {
-        int maxNumber = int.MinValue;
-        foreach (int number in numbers)
-        {
-            if (number > maxNumber)
-            {
-                maxNumber = number;
-            }
-        }
-        return maxNumber;
-    }
-
-    static int CountNumbers(int[] numbers, int targetNumber)
-    {
-        int count = 0;
-        foreach (int number in numbers)
-        {
-            if (number == targetNumber)
-            {
-                count++;
-            }
-        }
-        return count;
-    }
-
-    static void SaveCountToFile(string filePath, int count)
-    {
-        File.WriteAllText(filePath, count.ToString());
-    }        

tasks/zinoveva-ad/lab_2/worker-2/worker-2.csproj

@@ -1,9 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-  <PropertyGroup>
-    <OutputType>Exe</OutputType>
-    <TargetFramework>net5.0</TargetFramework>
-    <RootNamespace>worker_2</RootNamespace>
-  </PropertyGroup>
-
-</Project>

tasks/zinoveva-ad/lab_4/4Lab_python/.idea/.gitignore

@@ -0,0 +1,3 @@
+# Default ignored files
+/shelf/
+/workspace.xml

tasks/zinoveva-ad/lab_4/4Lab_python/.idea/.name

@@ -0,0 +1 @@
+receive.py

tasks/zinoveva-ad/lab_4/4Lab_python/.idea/inspectionProfiles/profiles_settings.xml

@@ -0,0 +1,6 @@
+<component name="InspectionProjectProfileManager">
+  <settings>
+    <option name="USE_PROJECT_PROFILE" value="false" />
+    <version value="1.0" />
+  </settings>
+</component>

tasks/zinoveva-ad/lab_4/4Lab_python/.idea/misc.xml

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="Black">
+    <option name="sdkName" value="Python 3.12 (python4Lab)" />
+  </component>
+  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.12 (python4Lab)" project-jdk-type="Python SDK" />
+</project>

tasks/zinoveva-ad/lab_4/4Lab_python/.idea/modules.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/python4Lab.iml" filepath="$PROJECT_DIR$/.idea/python4Lab.iml" />
+    </modules>
+  </component>
+</project>

tasks/zinoveva-ad/lab_4/4Lab_python/.idea/python4Lab.iml

@@ -0,0 +1,10 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="PYTHON_MODULE" version="4">
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$">
+      <excludeFolder url="file://$MODULE_DIR$/venv" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>

tasks/zinoveva-ad/lab_4/4Lab_python/.idea/vcs.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$/../../../.." vcs="Git" />
+  </component>
+</project>

tasks/zinoveva-ad/lab_4/4Lab_python/Python.gitignore

@@ -0,0 +1,160 @@
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+share/python-wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.nox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+*.py,cover
+.hypothesis/
+.pytest_cache/
+cover/
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+local_settings.py
+db.sqlite3
+db.sqlite3-journal
+
+# Flask stuff:
+instance/
+.webassets-cache
+
+# Scrapy stuff:
+.scrapy
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+.pybuilder/
+target/
+
+# Jupyter Notebook
+.ipynb_checkpoints
+
+# IPython
+profile_default/
+ipython_config.py
+
+# pyenv
+#   For a library or package, you might want to ignore these files since the code is
+#   intended to run in multiple environments; otherwise, check them in:
+# .python-version
+
+# pipenv
+#   According to pypa/pipenv#598, it is recommended to include Pipfile.lock in version control.
+#   However, in case of collaboration, if having platform-specific dependencies or dependencies
+#   having no cross-platform support, pipenv may install dependencies that don't work, or not
+#   install all needed dependencies.
+#Pipfile.lock
+
+# poetry
+#   Similar to Pipfile.lock, it is generally recommended to include poetry.lock in version control.
+#   This is especially recommended for binary packages to ensure reproducibility, and is more
+#   commonly ignored for libraries.
+#   https://python-poetry.org/docs/basic-usage/#commit-your-poetrylock-file-to-version-control
+#poetry.lock
+
+# pdm
+#   Similar to Pipfile.lock, it is generally recommended to include pdm.lock in version control.
+#pdm.lock
+#   pdm stores project-wide configurations in .pdm.toml, but it is recommended to not include it
+#   in version control.
+#   https://pdm.fming.dev/#use-with-ide
+.pdm.toml
+
+# PEP 582; used by e.g. github.com/David-OConnor/pyflow and github.com/pdm-project/pdm
+__pypackages__/
+
+# Celery stuff
+celerybeat-schedule
+celerybeat.pid
+
+# SageMath parsed files
+*.sage.py
+
+# Environments
+.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# Spyder project settings
+.spyderproject
+.spyproject
+
+# Rope project settings
+.ropeproject
+
+# mkdocs documentation
+/site
+
+# mypy
+.mypy_cache/
+.dmypy.json
+dmypy.json
+
+# Pyre type checker
+.pyre/
+
+# pytype static type analyzer
+.pytype/
+
+# Cython debug symbols
+cython_debug/
+
+# PyCharm
+#  JetBrains specific template is maintained in a separate JetBrains.gitignore that can
+#  be found at https://github.com/github/gitignore/blob/main/Global/JetBrains.gitignore
+#  and can be added to the global gitignore or merged into this file.  For a more nuclear
+#  option (not recommended) you can uncomment the following to ignore the entire idea folder.
+#.idea/

tasks/zinoveva-ad/lab_4/4Lab_python/main_task/Consumer_1.py

@@ -0,0 +1,20 @@
+import pika
+import time
+
+def process_message(ch, method, properties, body):
+    print(f"Получено сообщение: {body}")
+    time.sleep(3)
+    print("Сообщение успешно обработано")
+
+connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
+channel = connection.channel()
+
+result = channel.queue_declare(queue='', exclusive=True)
+queue_name = result.method.queue
+
+channel.queue_bind(exchange='Agreements', queue=queue_name)
+
+channel.basic_consume(queue=queue_name, on_message_callback=process_message, auto_ack=True)
+
+print('Ожидание сообщений...')
+channel.start_consuming()

tasks/zinoveva-ad/lab_4/4Lab_python/main_task/Consumer_2.py

@@ -0,0 +1,19 @@
+import pika
+
+
+def process_message(ch, method, properties, body):
+    print(f"Получено сообщение: {body}")
+    print("Сообщение успешно обработано")
+
+connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
+channel = connection.channel()
+
+result = channel.queue_declare(queue='', exclusive=True)
+queue_name = result.method.queue
+
+channel.queue_bind(exchange='Agreements', queue=queue_name)
+
+channel.basic_consume(queue=queue_name, on_message_callback=process_message, auto_ack=True)
+
+print('Ожидание сообщений...')
+channel.start_consuming()

tasks/zinoveva-ad/lab_4/4Lab_python/main_task/Publisher.py

@@ -0,0 +1,19 @@
+import pika
+import time
+import random
+
+collection = ["the employment document", "The document is agreed", "Signatures are provided", "the employee is accepted"]
+
+connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
+channel = connection.channel()
+
+channel.exchange_declare(exchange='Agreements', exchange_type='fanout')
+
+while True:
+    message = f"Message: {random.choice(collection)}"
+
+    channel.basic_publish(exchange='Agreements', routing_key='', body=message)
+
+    time.sleep(1)
+
+connection.close()

tasks/zinoveva-ad/lab_4/4Lab_python/tutorial_1/receive.py

@@ -0,0 +1,25 @@
+import pika, sys, os
+
+def main():
+    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
+    channel = connection.channel()
+
+    channel.queue_declare(queue='Logs')
+
+    def callback(ch, method, properties, body):
+        print(f" [x] Получено сообщение: {body}")
+
+    channel.basic_consume(queue='Logs', on_message_callback=callback, auto_ack=True)
+
+    print(' [*] Ожидание сообщений. Для завершения CTRL+C')
+    channel.start_consuming()
+
+if __name__ == '__main__':
+    try:
+        main()
+    except KeyboardInterrupt:
+        print('Произошла ошибка')
+        try:
+            sys.exit(0)
+        except SystemExit:
+            os._exit(0)

tasks/zinoveva-ad/lab_4/4Lab_python/tutorial_1/send.py

@@ -0,0 +1,11 @@
+import pika
+
+connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
+channel = connection.channel()
+
+channel.queue_declare(queue='sentimental_anna')
+
+channel.basic_publish(exchange='',routing_key='sentimental_anna',body='Hello, I have a cat, Busia, and a dog, Bonya!')
+print(" [x] Отправлено сообщение")
+
+connection.close()

tasks/zinoveva-ad/lab_4/4Lab_python/tutorial_2/new_task.py

@@ -0,0 +1,13 @@
+import pika
+import sys
+
+connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
+channel = connection.channel()
+
+channel.queue_declare(queue='sentimental_anna2', durable=True)
+
+message = ' '.join(sys.argv[1:]) or "Hello I have a cat, Busia, and a dog, Bonya!"
+channel.basic_publish(exchange='', routing_key='sentimental_anna2', body=message, properties=pika.BasicProperties(
+        delivery_mode=pika.spec.PERSISTENT_DELIVERY_MODE))
+print(f" [x] Отправлено {message}")
+connection.close()

tasks/zinoveva-ad/lab_4/4Lab_python/tutorial_2/worker.py

@@ -0,0 +1,19 @@
+import pika
+import time
+
+connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
+channel = connection.channel()
+
+channel.queue_declare(queue='sentimental_anna2', durable=True)
+print(' [*] Ожидание сообщений. Для завершения CTRL+C')
+
+def callback(ch, method, properties, body):
+    print(f" [x] Получено сообщение: {body.decode()}")
+    time.sleep(body.count(b'.'))
+    print(" [x] Выполнено")
+    ch.basic_ack(delivery_tag=method.delivery_tag)
+
+channel.basic_qos(prefetch_count=1)
+channel.basic_consume(queue='sentimental_anna2', on_message_callback=callback)
+
+channel.start_consuming()

tasks/zinoveva-ad/lab_4/4Lab_python/tutorial_3/emit_log.py

@@ -0,0 +1,12 @@
+import pika
+import sys
+
+connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
+channel = connection.channel()
+
+channel.exchange_declare(exchange='Logs', exchange_type='fanout')
+
+message = ' '.join(sys.argv[1:]) or "Info: Hello I have a cat, Busia, and a dog, Bonya!"
+channel.basic_publish(exchange='Logs', routing_key='', body=message)
+print(f" [x] Отправлено сообщение: {message}")
+connection.close()

tasks/zinoveva-ad/lab_4/4Lab_python/tutorial_3/receive_logs.py

@@ -0,0 +1,21 @@
+import pika
+
+connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
+channel = connection.channel()
+
+channel.exchange_declare(exchange='Logs', exchange_type='fanout')
+
+result = channel.queue_declare(queue='', exclusive=True)
+queue_name = result.method.queue
+
+channel.queue_bind(exchange='Logs', queue=queue_name)
+
+print(' [*] Ожидание сообщений. Для завершения CTRL+C')
+
+def callback(ch, method, properties, body):
+    print(f" [x] {body}")
+
+channel.basic_consume(
+    queue=queue_name, on_message_callback=callback, auto_ack=True)
+
+channel.start_consuming()

tasks/zinoveva-ad/lab_4/README.md

@@ -0,0 +1,118 @@
+# Отчет по лабораторной работе №4
+
+Выполнила студентка гр. ИСЭбд-41 Зиновьева А. Д.
+
+## Прохождение tutorial
+
+Установила rabbitMQ server, erlang и зашла в брокер под гостем по http://localhost:15672/#/ 
+![](pic/Screenshot_7.jpg)
+
+Туториал 1:
+
+![](pic/Screenshot_1.jpg)
+![](pic/Screenshot_2.jpg)
+![](pic/Screenshot_3.jpg)
+
+Туториал 2:
+
+![](pic/Screenshot_4.jpg)
+![](pic/Screenshot_5.jpg)
+![](pic/Screenshot_8.jpg)
+
+Туториал 3:
+
+![](pic/Screenshot_9.jpg)
+![](pic/Screenshot_10.jpg)
+![](pic/Screenshot_11.jpg)
+
+## Разработка демонстрационных приложений
+
+Предметная область: Дополнительный соглашения и договоры на проживание.
+Разработаны три приложения, согласно предметной области.
+
+1. Publisher
+
+```py
+import pika
+import time
+import random
+
+collection = ["the employment document", "The document is agreed", "Signatures are provided", "the employee is accepted"]
+
+connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
+channel = connection.channel()
+
+channel.exchange_declare(exchange='Agreements', exchange_type='fanout')
+
+while True:
+    message = f"Message: {random.choice(collection)}"
+
+    channel.basic_publish(exchange='Agreements', routing_key='', body=message)
+
+    time.sleep(1)
+
+connection.close()
+```
+
+2. Consumer 1.
+
+```py
+import pika
+import time
+
+def process_message(ch, method, properties, body):
+    print(f"Получено сообщение: {body}")
+    time.sleep(3)
+    print("Сообщение успешно обработано")
+
+connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
+channel = connection.channel()
+
+result = channel.queue_declare(queue='', exclusive=True)
+queue_name = result.method.queue
+
+channel.queue_bind(exchange='Agreements', queue=queue_name)
+
+channel.basic_consume(queue=queue_name, on_message_callback=process_message, auto_ack=True)
+
+print('Ожидание сообщений...')
+channel.start_consuming()
+```
+
+3. Consumer 2.
+
+```py
+import pika
+
+
+def process_message(ch, method, properties, body):
+    print(f"Получено сообщение: {body}")
+    print("Сообщение успешно обработано")
+
+connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
+channel = connection.channel()
+
+result = channel.queue_declare(queue='', exclusive=True)
+queue_name = result.method.queue
+
+channel.queue_bind(exchange='Agreements', queue=queue_name)
+
+channel.basic_consume(queue=queue_name, on_message_callback=process_message, auto_ack=True)
+
+print('Ожидание сообщений...')
+channel.start_consuming()
+```
+
+## Результаты выполнения лабораторной работы
+
+Результат отработки Consumer_1:
+
+![](pic/Screenshot_16.jpg)
+![](pic/Screenshot_13.jpg)
+
+Результат отработки Consumer_2:
+
+![](pic/Screenshot_17.jpg)
+![](pic/Screenshot_15.jpg)
+
+Вывод: Consumer_2 нагружает меньше памяти, чем Consumer_1 и принимает сообщения гораздо быстрее, тем самым не позволяя очереди накапливать огромное количество сообщений.