- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我目前正在开发一个解析应用程序,它首先从远程服务器获取 .csv
文件,然后将其同步到本地服务器。同步后,从本地路径下载的文件将被解析,然后插入到 SQL 数据库中。如果从远程服务器添加了新文件(然后同步到本地服务器),应用程序如何知道只解析那些特定的新文件(防止重新解析和重新插入旧的 .csv 文件)已经解析)?
到目前为止我的代码:
public static int Main()
{
try
{
// Setup session options
SessionOptions sessionOptions = new SessionOptions
{
Protocol = Protocol.Scp,
HostName = hostName,
UserName = userName,
Password = passWord,
SshHostKeyFingerprint = sshHostKey
};
using (Session session = new Session())
{
// Will continuously report progress of synchronization
session.FileTransferred += FileTransferred;
// Connect
session.Open(sessionOptions);
// Synchronize files
SynchronizationResult synchronizationResult;
synchronizationResult =
session.SynchronizeDirectories(
SynchronizationMode.Local, localPath, remotePath, false);
// Throw on any error
synchronizationResult.Check();
Run();
}
return 0;
}
catch (Exception e)
{
Console.WriteLine("Error: {0}", e);
Console.ReadLine();
return 1;
}
}
这处理同步文件时的事件:
private static void FileTransferred(object sender, TransferEventArgs e)
{
if (e.Error == null)
{
Console.WriteLine("Upload of {0} from remote to local server succeeded", e.FileName);
}
else
{
Console.WriteLine("Upload of {0} from remote to local server failed: {1}", e.FileName, e.Error);
}
if (e.Chmod != null)
{
if (e.Chmod.Error == null)
{
Console.WriteLine("Permisions of {0} set to {1}", e.Chmod.FileName, e.Chmod.FilePermissions);
}
else
{
Console.WriteLine("Setting permissions of {0} failed: {1}", e.Chmod.FileName, e.Chmod.Error);
}
}
else
{
Console.WriteLine("Permissions of {0} kept with their defaults", e.Destination);
}
if (e.Touch != null)
{
if (e.Touch.Error == null)
{
Console.WriteLine("Timestamp of {0} set to {1}", e.Touch.FileName, e.Touch.LastWriteTime);
}
else
{
Console.WriteLine("Setting timestamp of {0} failed: {1}", e.Touch.FileName, e.Touch.Error);
}
}
else
{
// This should never happen during "local to remote" synchronization
Console.WriteLine("Timestamp of {0} kept with its default (current time)", e.Destination);
}
}
这会解析 .csv
文件的内容。同步后发生。
public static void Run()
{
dataTable();
List<string> items = new List<string>();
foreach (string file in Directory.EnumerateFiles(localPath, "*.csv"))
{
if (file.Contains("test"))
{ }
else
{
using (FileStream fs = new FileStream(file, FileMode.Open, FileAccess.Read, FileShare.ReadWrite))
{
using (StreamReader sr = new StreamReader(fs))
{
while (!sr.EndOfStream)
items.Add(sr.ReadLine());
foreach (string item in items)
{
var row = dt.NewRow();
string[] columnValues = item.Split(',');
int column = 3;
for (int a = 0; a < columnValues.Length; a++)
{
string date = columnValues[29] + " " + columnValues[28];
row[col[1].ColumnName] = DateTime.Parse(date);
string test = file.Split(new[] { splitVal }, StringSplitOptions.None)[1];
row[col[2].ColumnName] = test.Split('.')[0];
if (a >= 54)
{ }
else
{
if (string.IsNullOrEmpty(columnValues[a]))
{
row[col[column].ColumnName] = DBNull.Value;
}
else
{
try
{
try
{
row[col[column].ColumnName] = columnValues[a].Trim();
}
catch
{
try
{
row[col[column].ColumnName] = Convert.ToDouble(columnValues[a].Trim());
}
catch
{
row[col[column].ColumnName] = int.Parse(columnValues[a].Trim());
}
}
}
catch (Exception ex)
{
Console.WriteLine("Error [" + col[column].ColumnName + "]:" + ex.ToString());
//row[col[column].ColumnName] = DBNull.Value;
}
}
}
column++;
}
dt.Rows.Add(row);
}
using (SqlConnection con = new SqlConnection(consstring))
{
using (SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(con))
{
//Set the database table name
sqlBulkCopy.DestinationTableName = dbTable;
con.Open();
try
{
sqlBulkCopy.WriteToServer(dt);
Console.WriteLine(file.Substring(file.LastIndexOf('\\') + 1) + " uploaded in the database\n");
}
catch (Exception ex)
{
Console.WriteLine(file.Substring(file.LastIndexOf('\\') + 1) + " cannot be uploaded to database. " + ex.ToString());
}
con.Close();
}
}
sr.Dispose();
sr.Close();
}
fs.Dispose();
fs.Close();
}
}
}
}
以上代码来自Session.SynchronizeDirectories Method WinSCP 的。
最佳答案
所以不要枚举所有的*.csv
文件。仅枚举那些已同步/下载的:
foreach (TransferEventArgs transfer in synchronizationResult.Downloads)
{
string file = transfer.Destination;
...
}
参见 SynchronizationResult
class .
如果您需要连续同步,则需要循环运行您的代码或安排它以频繁的时间间隔运行。请参阅 WinSCP 示例 Keep local directory up to date (download changed files from remote SFTP/FTP server) – 它在 PowerShell 中,但应该会给您一个想法。
关于c# - 识别新同步的文件 (WinSCP),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39588480/
我使用的是linux的windows子系统,安装了ubuntu,bash运行流畅。 我正在尝试使用make,似乎bash 无法识别gcc。尝试将其添加到 PATH,但没有任何改变。奇怪的是 - cmd
ImageMagick 已正确安装。 WAMP 的“PHP 扩展”菜单也显示带有勾选的 php_imagick。除了 Apache 和系统环境变量外,phpinfo() 没有显示任何 imagick
我是这么想的,因为上限是 2^n,并且考虑到它们都是有限机,n 状态 NFA 和具有 2^n 或更少状态的 DFA 的交集将是有效。 我错了吗? 最佳答案 你是对的。 2^n 是一个上限,因此生成的
我有一个大型数据集,其中包含每日值,指示一年中的特定一天是否特别热(用 1 或 0 表示)。我的目标是识别 3 个或更多特别炎热的日子的序列,并创建一个包含每个日子的长度以及开始和结束日期的新数据集。
我有一个向量列表,每个向量看起来像这样 c("Japan", "USA", "country", "Japan", "source", "country", "UK", "source", "coun
是否有任何工具或方法可以识别静态定义数组中的缓冲区溢出(即 char[1234] 而不是 malloc(1234))? 昨天我花了大部分时间来追踪崩溃和奇怪的行为,最终证明是由以下行引起的: // e
我一直在尝试通过导入制表符分隔的文件来手动创建 Snakemake 通配符,如下所示: dataset sample species frr PRJNA493818_GSE120639_SRP1628
我一直在尝试通过导入制表符分隔的文件来手动创建 Snakemake 通配符,如下所示: dataset sample species frr PRJNA493818_GSE120639_SRP1628
我想录下某人的声音,然后根据我获得的关于他/她声音的信息,如果那个人再次说话,我就能认出来!问题是我没有关于哪些统计数据(如频率)导致人声差异的信息,如果有人可以帮助我如何识别某人的声音? 在研究过程
我希望我的程序能够识别用户何时按下“enter”并继续循环播放。但是我不知道如何使程序识别“输入”。尝试了两种方法: string enter; string ent = "\n"; dice d1;
我创建了这个带有一个参数(文件名)的 Bash 小脚本,该脚本应该根据文件的扩展名做出响应: #!/bin/bash fileFormat=${1} if [[ ${fileFormat} =~ [F
我正在寻找一种在 for 循环内迭代时识别 subview 对象的方法,我基本上通过执行 cell.contentView.subviews 从 UITableView 的 contentView 获
我正在尝试在 Swift 中使用 CallKit 来识别调用者。 我正在寻找一种通过发出 URL 请求来识别调用者的方法。 例如:+1-234-45-241 给我打电话,我希望它向 mydomain.
我将(相当古老的)插件称为“thickbox”,如下所述: 创建厚盒时,它包含基于查询的内容列表。 使用 JavaScript 或 jQuery,我希望能够访问 type 的值(在上面的示例中 t
我想编写一些可以接受某种输入并将其识别为方波、三角波或某种波形的代码。我还需要一些产生所述波的方法。 我确实有使用 C/C++ 的经验,但是,我不确定我将如何模拟所有这些。最终,我想将其转换为微 Co
我创建了一个 for 循环,用于在每个部分显示 8 个项目,但我试图在循环中识别某些项目。例如,我想识别前两项,然后是第五项和第六项,但我的识别技术似乎是正确的。 for (int i = 0; i
如何识别 UIStoryboard? 该类具有创建和实例化的方法,但我没有看到带有类似name 的@property。例如 获取 Storyboard对象 + storyboardWithName:b
如何确定所运行的SQLServer2005的版本 要确定所运行的SQLServer2005的版本,请使用SQLServerManagementStudio连接到SQLServer2005,然后运行
这个问题在这里已经有了答案: How to check whether an object is a date? (26 个答案) 关闭2 年前。 我正在使用一个 npm 模块,它在错误时抛出一个空
我正在制作一个使用 ActivityRecognition API 在后台跟踪用户 Activity 的应用,如果用户在指定时间段(例如 1 小时)内停留在同一个地方,系统就会推送通知告诉用户去散步.
我是一名优秀的程序员,十分优秀!